in backfill/2024-04-29-fxa_events/backend/backfill_backend_users_services_daily.py [0:0]
def do_job(current_date):
current_partition = current_date.strftime('%Y%m%d')
current_date_str = current_date.strftime('%Y-%m-%d')
dest_table = f"akomar_accounts_backend_users_services_daily_v2${current_partition}"
arguments = (
['query', '--use_legacy_sql=false', '--replace', '--project_id=moz-fx-data-shared-prod',
'--format=none', f'--parameter=submission_date:DATE:{current_date_str}']
+ [f'--dataset_id=mozdata:analysis']
+ [f'--destination_table={dest_table}']
)
print(f"Running backfill to {dest_table}")
with open('users_services_daily_v2.sql', 'r') as file:
subprocess.check_call(["bq"] + arguments, stdin=file)