Skip to content

Commit a033bfe

Browse files
committed
Update submit() abstract interface
1 parent 5069fa6 commit a033bfe

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

src/aleph/sdk/client/abstract.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -428,7 +428,8 @@ async def submit(
428428
storage_engine: StorageEnum = StorageEnum.storage,
429429
allow_inlining: bool = True,
430430
sync: bool = False,
431-
) -> Tuple[AlephMessage, MessageStatus]:
431+
raise_on_rejected: bool = True,
432+
) -> Tuple[AlephMessage, MessageStatus, Optional[Dict[str, Any]]]:
432433
"""
433434
Submit a message to the network. This is a generic method that can be used to submit any type of message.
434435
Prefer using the more specific methods to submit messages.
@@ -439,6 +440,7 @@ async def submit(
439440
:param storage_engine: Storage engine to use (Default: "storage")
440441
:param allow_inlining: Whether to allow inlining the content of the message (Default: True)
441442
:param sync: If true, waits for the message to be processed by the API server (Default: False)
443+
:param raise_on_rejected: Whether to raise an exception if the message is rejected (Default: True)
442444
"""
443445
pass
444446

src/aleph/sdk/client/authenticated_http.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -404,6 +404,7 @@ async def create_store(
404404
allow_inlining=True,
405405
sync=sync,
406406
)
407+
return message, status
407408

408409
async def create_program(
409410
self,

0 commit comments

Comments
 (0)