dag.py

with models.DAG() as dag:
    dataset = 'BREATHE'
    
    # create a task for each table in the BREATHE dataset
    for table_name in list_breathe_tables():  
      destination_uri = 'gs://' + '/'.join((dest_bucket,
                                  '{{ ds_nodash }}', # one day is enough for the full snapshot
                                  table_name,
                                  table_name + '-{{ ds_nodash }}-*.jsonl'))
      
      logger.info('generating task to transfer table: %s to %s', table_source, destination_uri)
      task = bigquery_to_gcs.BigQueryToCloudStorageOperator(
              source_project_dataset_table=table_name,
              destination_cloud_storage_uris=[destination_uri],
              compression='NONE',
              export_format='NEWLINE_DELIMITED_JSON'
          )