Skip to content
Snippets Groups Projects

Added port constrain to list scheduler, added example and updated tests

Merged Simon Bjurek requested to merge add-port-access-constrain-in-sched into master
All threads resolved!
Files
38
+ 7
0
@@ -396,6 +396,13 @@ class ProcessingElement(Resource):
assign: bool = True,
):
super().__init__(process_collection=process_collection, entity_name=entity_name)
if not isinstance(process_collection, ProcessCollection):
raise TypeError(
"Argument process_collection must be ProcessCollection, "
f"not {type(process_collection)}"
)
if not all(
isinstance(operator, OperatorProcess)
for operator in process_collection.collection
Loading