Exception in run_pipeline: UnboundLocalError
Traceback (most recent call last):
  File "/worker/shared/logging/ps_logging.py", line 58, in wrapper
    result = func(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^^^
  File "/worker/shared/task_handlers/run_pipeline/pipeline.py", line 2241, in run_pipeline
    pipeline_tables = extract_pipeline_tables_from_query(query)
                                                         ^^^^^
UnboundLocalError: cannot access local variable 'query' where it is not associated with a value