Error creating dlt source to run query
Traceback (most recent call last):
  File "/app/app/data_pipeline.py", line 773, in run_pipeline
    dlt_source = query_source(engine, query=query)
UnboundLocalError: local variable 'engine' referenced before assignment