text: from airflow import DAG
  from operators.partner_snapshot import PartnerSnapshotOperator
  from datetime import datetime
  from config import config
  
  from skills_ml.datasets.partner_updaters import USAJobsUpdater
  
  
  default_args = {
      'depends_on_past': False,
      'start_date': datetime(2017, 5, 1),
  }
  
  dag = DAG(
      dag_id='partner_nightly',
      default_args=default_args,
      schedule_interval='@daily',
      max_active_runs=1
  )
  
  raw_jobs = config.get('raw_jobs_s3_paths', {})
  
  usa_jobs_credentials = config.get('usa_jobs_credentials', {})
  if raw_jobs and usa_jobs_credentials:
      PartnerSnapshotOperator(
          task_id='usa_jobs_update',
          dag=dag,
          s3_prefix=raw_jobs['US'],
          updater_class=USAJobsUpdater,
          passthrough_kwargs=usa_jobs_credentials
      )
  