"""Config for VEVO Ingestion Workflow.""" import os environment = os.environ.get('Environment', 'dev') feed_name = 'vevo' secrets_path = 'vevo' # filename template filename = ( 'The_Orchard_Vevo_YouTube_Active_Claims_Metadata' '_{date:%Y-%m-%d}T{{postfix}}.csv') filename_theorchard_prefix = ( 'The_Orchard_Vevo_YouTube_Active_Claims_Metadata_{date:%Y-%m-%d}T') filename_sme = 'active_claims_{date:%Y%m%d}.csv.gz' # bucket for dropped data drop_bucket = os.environ.get( 'FEED_INGESTION_DROP_BUCKET', 'dev-feed-drop') drop_bucket_sme = os.environ.get( 'SME_FEED_INGESTION_DROP_BUCKET', 'sme-data-archive') if environment == 'production': drop_bucket = 'prod-orcdbucket' # bucket for archived data data_bucket = os.environ.get( 'FEED_INGESTION_DATA_BUCKET', 'dev-cucumbers') if environment == 'production': data_bucket = 'cucumbers' # S3 locations for dropped and archived files s3 = { 'theorchard': { 'drop': 'feed-drop/Vevo/', 'archive': 'Vevo/archives/{date:%Y-%m-%d}/'}, 'sme': { 'drop': ( 'vevo/active_claims/v1/' 'report_date={date:%Y-%m-%d}/report_licensor=sme/'), 'archive': 'Vevo/archives_sme/{date:%Y-%m-%d}/', 'v2_switch_date': '2026-04-02'} } # snowflake table name template staging_raw_table = 'staging_raw_vevo' temp_staging_raw_table = 'temp_staging_raw_vevo_{licensor}_{date:%Y%m%d}' snowflake_error_limit = 10 # to get sme files sme_role_arn = os.environ.get('ROLE_ARN')