This message was deleted.
# ask-marvin
s
This message was deleted.
m
Your message was too long, here's your message at the allowed limit: ### Bug summary ### Bug summary etl py
Copy code
python from datetime import date from workflows flows etl import extraction_and_transformation if __name__ == __main__ extraction_and_transformation serve( name= Extraction Transformation Loading parameters={ source_name ABC database_export_date date(2025 8 27) bucket_name data-migration } )
workflows/flows/etl py
Copy code
python @flow(name= Data Extraction and Transformation ) def extraction_and_transformation( source_name str database_export_date date bucket_name str ) from prefect runtime import flow_run deployment task_run print( prefect version prefect __version__) print( Deployment Parameters deployment parameters) print( Flow Run Parameters flow_run parameters) print( Task Run Parameters task_run parameters) print( Flow Run Parent Deployment ID flow_run parent_deployment_id)
I bring up all the services including prefect-server and worker using
docker compose -f docker/prefect yml up
Copy code
python zap docker compose -f docker/prefect yml run --rm cli -c 'uv run etl py' WARN[0000] Found orphan containers ([mssql]) for this project If you removed or renamed this service in your compose file you can run this command with the --remove-orphans flag to clean it up Bytecode compiled 7866 files in 145ms Your flow 'Data Extraction and Transformation' is being served and polling for scheduled runs! To trigger a run for this flow use the following command $ prefect deployment run 'Data Extraction and Transformation/Extraction Transformation Loading' You can also run your flow via the Prefect UI <http //prefect-server 4200/deployments/deployment/d76006a0-db1a-41fa-b763-3b98b822581d> 11 31 08 449 | INFO | prefect flow_runs runner - Runner 'Extraction Transformation Loading' submitting flow run 'cd01b0cb-0c2e-4136-aa3c-25dd4357c220' 11 31 08 491 | INFO | prefect flow_runs runner - Completed submission of flow run 'cd01b0cb-0c2e-4136-aa3c-25dd4357c220' 11 31 09 063 | INFO | Flow run 'uptight-mussel' - Beginning flow run 'uptight-mussel' for flow 'Data Extraction and Transformation' 11 31 09 065 | INFO | Flow run 'uptight-mussel' - View at <http //prefect-server 4200/runs/flow-run/cd01b0cb-0c2e-4136-aa3c-25dd4357c220> prefect version 3 4 20 Deployment Parameters {'bucket_name' 'data-migration' 'source_name' 'ABC' 'database_export_date' '2025-08-27'} Flow Run Parameters {'source_name' 'ABC' 'database_export_date' datetime date(2025 8 27) 'bucket_name' 'data-migration'} Task Run Parameters {}
```python zap docker compose -f docker/prefect yml run --rm cli -c 'uv run etl py' WARN[0000] Found orphan containers ([mssql]) for this project If you removed or renamed this service in your compose file you can run this command with the --remove-orphans flag to clean it up Bytecode compiled 7921 files in 139ms Your flow 'Data Extraction and Transformation' is being served and polling for scheduled runs! To trigger a run for this flow use the following command $ prefect deployment run 'Data Extraction and Transformation/Extraction Transformation Loading' You can also run your flow via the Prefect UI <http //prefect-server 4200/deployments/deployment/d76006a0-db1a-41fa-b763-3b98b822581d> 11 39 08 484 | INFO | prefect flow_runs runner - Runner 'Extraction Transformation Loading' submitting flow run '009e52a4-9bc7-4689-9dcb-1fdb65aa8768' 11 39 08 526 | INFO | prefect flow_runs runner - Completed submission of flow run '009e52a4-9bc7-4689-9dcb-1fdb65aa8768' 11 39 09 093 | INFO | Flow run 'curious-mink' - Beginning flow run 'curious-mink' for flow 'Data Extraction and Transformation' 11 39 09 095 | INFO | Flow run 'curious-mink' - View at <http //prefect-server 4200/runs/flow-run/009e52a4-9bc7-4689-9dcb-1fdb65aa8768> prefect version 3 4 21 Deployment Parameters {}
a
sure