Skip to content

Commit 80ee74a

Browse files
MHHukiewitzhoh
authored andcommitted
add metadata parameter to create_program()
1 parent 2c6a1b0 commit 80ee74a

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

src/aleph/sdk/client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -377,6 +377,7 @@ def create_program(
377377
encoding: Encoding = Encoding.zip,
378378
volumes: Optional[List[Mapping]] = None,
379379
subscriptions: Optional[List[Mapping]] = None,
380+
metadata: Optional[Mapping[str, Any]] = None,
380381
) -> Tuple[ProgramMessage, MessageStatus]:
381382
return self._wrap(
382383
self.async_session.create_program,
@@ -395,6 +396,7 @@ def create_program(
395396
encoding=encoding,
396397
volumes=volumes,
397398
subscriptions=subscriptions,
399+
metadata=metadata,
398400
)
399401

400402
def forget(
@@ -1170,6 +1172,7 @@ async def create_program(
11701172
encoding: Encoding = Encoding.zip,
11711173
volumes: Optional[List[Mapping]] = None,
11721174
subscriptions: Optional[List[Mapping]] = None,
1175+
metadata: Optional[Mapping[str, Any]] = None,
11731176
) -> Tuple[ProgramMessage, MessageStatus]:
11741177
"""
11751178
Post a (create) PROGRAM message.
@@ -1243,6 +1246,7 @@ async def create_program(
12431246
},
12441247
"volumes": volumes,
12451248
"time": time.time(),
1249+
"metadata": metadata,
12461250
}
12471251
)
12481252

tests/unit/test_asynchronous.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,7 @@ async def test_create_program(mock_session_with_post_success):
130130
entrypoint="main:app",
131131
runtime="facefacefacefacefacefacefacefacefacefacefacefacefacefacefaceface",
132132
channel="TEST",
133+
metadata={"tags": ["test"]}
133134
)
134135

135136
assert mock_session_with_post_success.http_session.post.called_once

0 commit comments

Comments
 (0)