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