@@ -378,6 +378,7 @@ def create_program(
378378 encoding : Encoding = Encoding .zip ,
379379 volumes : Optional [List [Mapping ]] = None ,
380380 subscriptions : Optional [List [Mapping ]] = None ,
381+ metadata : Optional [Mapping [str , Any ]] = None ,
381382 ) -> Tuple [ProgramMessage , MessageStatus ]:
382383 return self ._wrap (
383384 self .async_session .create_program ,
@@ -396,6 +397,7 @@ def create_program(
396397 encoding = encoding ,
397398 volumes = volumes ,
398399 subscriptions = subscriptions ,
400+ metadata = metadata ,
399401 )
400402
401403 def forget (
@@ -1171,6 +1173,7 @@ async def create_program(
11711173 encoding : Encoding = Encoding .zip ,
11721174 volumes : Optional [List [Mapping ]] = None ,
11731175 subscriptions : Optional [List [Mapping ]] = None ,
1176+ metadata : Optional [Mapping [str , Any ]] = None ,
11741177 ) -> Tuple [ProgramMessage , MessageStatus ]:
11751178 """
11761179 Post a (create) PROGRAM message.
@@ -1244,6 +1247,7 @@ async def create_program(
12441247 },
12451248 "volumes" : volumes ,
12461249 "time" : time .time (),
1250+ "metadata" : metadata ,
12471251 }
12481252 )
12491253
0 commit comments