From a212da3a4b8b6896a53022c2f0aa1f8558aeff82 Mon Sep 17 00:00:00 2001
From: Mike Hukiewitz <mike.hukiewitz@robotter.ai>
Date: Wed, 1 Mar 2023 14:21:05 +0100
Subject: [PATCH] Feature: parameter 'metadata' was missing from create_program

---
 src/aleph/sdk/client.py         | 4 ++++
 tests/unit/test_asynchronous.py | 1 +
 2 files changed, 5 insertions(+)

diff --git a/src/aleph/sdk/client.py b/src/aleph/sdk/client.py
index 26ae8550..5cb7e6b5 100644
--- a/src/aleph/sdk/client.py
+++ b/src/aleph/sdk/client.py
@@ -377,6 +377,7 @@ def create_program(
         encoding: Encoding = Encoding.zip,
         volumes: Optional[List[Mapping]] = None,
         subscriptions: Optional[List[Mapping]] = None,
+        metadata: Optional[Mapping[str, Any]] = None,
     ) -> Tuple[ProgramMessage, MessageStatus]:
         return self._wrap(
             self.async_session.create_program,
@@ -395,6 +396,7 @@ def create_program(
             encoding=encoding,
             volumes=volumes,
             subscriptions=subscriptions,
+            metadata=metadata,
         )
 
     def forget(
@@ -1170,6 +1172,7 @@ async def create_program(
         encoding: Encoding = Encoding.zip,
         volumes: Optional[List[Mapping]] = None,
         subscriptions: Optional[List[Mapping]] = None,
+        metadata: Optional[Mapping[str, Any]] = None,
     ) -> Tuple[ProgramMessage, MessageStatus]:
         """
         Post a (create) PROGRAM message.
@@ -1243,6 +1246,7 @@ async def create_program(
                 },
                 "volumes": volumes,
                 "time": time.time(),
+                "metadata": metadata,
             }
         )
 
diff --git a/tests/unit/test_asynchronous.py b/tests/unit/test_asynchronous.py
index 7ce54906..00fbbfbf 100644
--- a/tests/unit/test_asynchronous.py
+++ b/tests/unit/test_asynchronous.py
@@ -130,6 +130,7 @@ async def test_create_program(mock_session_with_post_success):
             entrypoint="main:app",
             runtime="facefacefacefacefacefacefacefacefacefacefacefacefacefacefaceface",
             channel="TEST",
+            metadata={"tags": ["test"]},
         )
 
     assert mock_session_with_post_success.http_session.post.called_once