We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 31108ed commit 9fe7afaCopy full SHA for 9fe7afa
1 file changed
crates/fluxqueue-worker/scripts/get_registry.py
@@ -19,8 +19,14 @@ def get_registry( # noqa: C901
19
registry = {"tasks": {}, "contexts": {}}
20
for _name, obj in inspect.getmembers(module):
21
if inspect.isfunction(obj):
22
+ is_fluxqueue_task = getattr(obj, "fluxqueue", False)
23
+
24
+ if not is_fluxqueue_task:
25
+ continue
26
27
task_name = getattr(obj, "task_name", None)
28
task_queue = getattr(obj, "queue", None)
29
30
if not task_queue or task_queue != queue:
31
continue
32
0 commit comments