Skip to content

Commit

Permalink
pass pep8
Browse files Browse the repository at this point in the history
  • Loading branch information
alifradi committed Sep 22, 2024
1 parent 9026ce0 commit fd430ac
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions dags/etl_dags.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,21 +21,21 @@

extract_task = DockerOperator(
task_id='extract_task',
image='Dockerfile.extract',
image='Dockerfile.extract',
api_version='auto',
auto_remove=True,
command='/bin/bash -c "python pull_data.py"',
command='/bin/bash -c "python pull_data.py"',
docker_url='unix://var/run/docker.sock',
network_mode='bridge',
volumes=['/data:/data', '/output:/clean_data'],
)

transform_and_load_task = DockerOperator(
task_id='transform_and_load_task',
image='Dockerfile.transform_load',
image='Dockerfile.transform_load',
api_version='auto',
auto_remove=True,
command='/bin/bash -c "Rscript transform_load.R"',
command='/bin/bash -c "Rscript transform_load.R"',
docker_url='unix://var/run/docker.sock',
network_mode='bridge',
volumes=['/data:/data', '/output:/clean_data'],
Expand Down

0 comments on commit fd430ac

Please sign in to comment.