Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
  • Loading branch information
davedavemckay committed Dec 20, 2024
1 parent 94ce3f2 commit 28ce461
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions echo-side/dags/process_new_zips.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ def dl_bucket_names(url):

def print_bucket_name(bucket_name):
print(bucket_name)

# Define default arguments for the DAG
default_args = {
'owner': 'airflow',
Expand All @@ -37,7 +37,7 @@ def print_bucket_name(bucket_name):
'process_zips',
default_args=default_args,
description='Runs process_collated_zips.py',
schedule_interval=timedelta(days=1),
schedule=timedelta(days=1),
start_date=datetime(2024, 1, 1),
catchup=False,
) as dag:
Expand Down Expand Up @@ -68,5 +68,4 @@ def print_bucket_name(bucket_name):
# print('No bucket names found.')

print_bucket_name_task
process_zips_task

process_zips_task

0 comments on commit 28ce461

Please sign in to comment.