Mirror of https://github.com/roostorg/osprey
github.com/roostorg/osprey
fix `object is not subscriptable` when registering input stream (#13)
+4
-4
+4
-4
osprey_worker/src/osprey/worker/adaptor/plugin_manager.py
+4
-4
osprey_worker/src/osprey/worker/adaptor/plugin_manager.py
···
85
85
def bootstrap_input_stream() -> BaseInputStream[BaseAckingContext[Action]] | None:
86
86
load_all_osprey_plugins()
87
87
88
-
streams = plugin_manager.hook.register_input_stream()
89
-
if streams:
90
-
# spec has firstresult=True set, so at most it will be one.
91
-
return streams[0]
88
+
# spec has firstresult=True set, so it will return the first registered stream if one is registered
89
+
stream = plugin_manager.hook.register_input_stream()
90
+
if stream:
91
+
return stream
92
92
else:
93
93
return None