File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -436,16 +436,18 @@ async def submit(
436436 storage_engine : StorageEnum = StorageEnum .storage ,
437437 allow_inlining : bool = True ,
438438 sync : bool = False ,
439- ) -> Tuple [AlephMessage , MessageStatus ]:
440- resp , status = await self .session .submit (
439+ raise_on_rejected : bool = True ,
440+ ) -> Tuple [AlephMessage , MessageStatus , Optional [Dict [str , Any ]]]:
441+ message , status , response = await self .session .submit (
441442 content = content ,
442443 message_type = message_type ,
443444 channel = channel ,
444445 storage_engine = storage_engine ,
445446 allow_inlining = allow_inlining ,
446447 sync = sync ,
448+ raise_on_rejected = raise_on_rejected
447449 )
448450 if status in [MessageStatus .PROCESSED , MessageStatus .PENDING ]:
449- self .add (resp )
450- asyncio .create_task (self .delete_if_rejected (resp .item_hash ))
451- return resp , status
451+ self .add (message )
452+ asyncio .create_task (self .delete_if_rejected (message .item_hash ))
453+ return message , status , response
You can’t perform that action at this time.
0 commit comments