Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- upload_to_s3_task = PythonOperator(
- task_id='upload_file_to_s3',
- python_callable=upload_s3_file,
- op_kwargs={
- 'bucket_name': 'my-s3-bucket',
- 'key_name': 'my_s3_file.csv',
- 'local_file_path': 'path/to/my_file.csv',
- },
- dag=my_dag)
Add Comment
Please, Sign In to add comment
