Error creating dlt source to run query
Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 936, in run_pipeline
    engine, query=query, backend="pyarrow", name=step["name"]
UnboundLocalError: local variable 'engine' referenced before assignment