i 0dZddlZddlmZddlmZddlmZddlm Z m Z m Z m Z ddl mZddlmZdd lmZmZdd lmZmZdd lmZdd lmZmZd Zej:j<ZdZ dZ!dZ"dZ#dZ$dZ%dZ&ejNjQeeZ)e*e)jVe k7re,de)jVde e$de-de"e-de)jVe-de)j\e-de)j^e-de)j`e-de)jbe-de)jde-de)jfejNjie)ejjjlejnjp Z9ejNjie)e!Z:e:jiejvjlejxjlejzjlg"Z>ejNjie)e!Z?e?jiejvjlejxjlejzjlg"Z@e jNjie)ejvjlejzjlg#ZAe jNjie)ejvjlejzjlg#ZBe jNjie)ejvjlejzjlg#ZCe jNjie)e jje jjxe jjg$ZGejNjie)ejjejjxg%ZIejNjie)ejjvejjejjg&ZMeNZOe)jfreOje)jfeOje&e>d'eOje&e@d'eOje&eAd(eOje&eBd(eOje&eCd(eOje&eId)eOje&eId*eOje&eMd(eReOZOe$d+e-d,e%e9e-d-e%e>e-d.e%e@e-d/e%eAe-d0e%eBe-d1e%eCe-d2e%eGe-d3e%eIe-d4e%eMe-d5eSeOeOdd6D] Z3e-d7e3eSeOd6kDre-d8eSeOd6z d9e"se$d:e-d;eTdejZUej5e9jejnjeU<ejNjie)j=jejzjld>e>jejjleUe!d?e@jejjleUe!d?eAjejzjle!d@eBjejzjle!d@eCjejzjle!ddABeGje jjze jje jjze jjze jjzeUCeIjejjzeUDeMjejjzeUDddde$dEe#r>dZ]dZ^eOD]&Z3 ejje3dFdGHe]dz Z](e-dKe]dLe^ne-dMe$dNe-dOy#1swYjxYw#ea$rZbe^dz Z^e-dIe3dJebYdZb[bzdZb[bwwxYw)Pa" Stop retry/alert bleeding for one Facebook ad account. Usage from repo root: uv run python manage.py shell < /tmp/stop_fb_account_336282307415329_spam.py Dry-run is the default. Apply changes with: APPLY=1 uv run python manage.py shell < /tmp/stop_fb_account_336282307415329_spam.py N) current_app) transaction)timezone)AdCreativeDataAdIdsCacheDataAdMetricCacheDataAccountSyncLog) UpdateStatus) SyncStatus)BreakdownSyncStatusPipelineSyncStatus)JobJobTask) UserRoleType)Account UserAccount336282307415329z$4e7e1ec9-8754-459e-b8b7-7620db56f52czmSuppressed manually: Facebook returned (#200) missing ads_management/ads_read for ad account 336282307415329.cFtdt|tdy)NzQ ================================================================================zP================================================================================)print)titles ,/tmp/stop_fb_account_336282307415329_spam.py print_sectionr&s / %L (Oc"|jS)N)count)qss rrr,s 88:rc t|jdi|ddijdi|dij|djS)N__isnullT)flat)listexclude values_listdistinct)r field_names rtask_ids_from_qsr(0s\    5 H-t45  %# % Zd +   r) ad_account_idplatformz"Refusing to run: resolved account z , expected Targetzapply=z account_id=zad_account_id=zname=z platform=zversion=zassets_update_status=zaccount.task_id=)accountrolestatus)r,r*) status__in)r,sync_status__in)r,overall_status__in)r, state__in) job__accountr2celery_task_idtask_idgroup_idchord_idzPlanned Changesz/active owner UserAccount rows to mark EXPIRED: z6pipeline rows PENDING/RUNNING/FAILED to mark SKIPPED: z7breakdown rows PENDING/RUNNING/FAILED to mark SKIPPED: zEAdIdsCacheData pending/failed rows to mark failed and clear task_id: zHAdMetricCacheData pending/failed rows to mark failed and clear task_id: zCAdCreativeData pending/failed rows to mark failed and cap retries: z)AccountSyncLog open rows to mark failed: z(Job queued/running rows to mark failed: z"JobTask open rows to mark failed: ztask ids to revoke: 2z z ... z morezDry RunzENo changes made. Re-run with APPLY=1 to update rows and revoke tasks.)r.last_token_check_time)pk)assets_update_statusr5)r. completed_at last_errorr4) sync_status error_messager5)r>r?r5creative_sync_retry_count)overall_status current_stagead_creative_sync_statusstats_sync_statusai_reports_status finished_at)staterGz Task RevokeTSIGTERM) terminatesignalzfailed to revoke z: zrevoked=z failed=zSkipped because REVOKE_TASKS=0DonezDSuppression applied for Facebook ad_account_id=336282307415329 only.)c__doc__osceleryr django.dbr django.utilsrcreative_module.modelsrrrr creative_module.typesr data_pipeline_module.constantsr data_pipeline_module.modelsr r jobs.modelsrrorganization_auth.constantsrorganization_auth.modelsrr AD_ACCOUNT_IDPlatformFACEBOOKPLATFORMEXPECTED_ACCOUNT_IDSUPPRESSION_REASONAPPLY REVOKE_TASKSrrr(objectsgetr,strid RuntimeErrorrr)ad_account_namer*versionr;r5filterOWNERvalueUserAccountStatusACTIVEactive_owner_qs pipeline_qsPENDINGRUNNINGFAILEDpipeline_open_qs breakdown_qsbreakdown_open_qsad_ids_open_qsmetric_open_qscreative_open_qs OverallStatusQUEUED RECONCILING run_open_qsJobState job_open_qs TaskStateRECEIVEDSTARTEDjob_task_open_qssettask_idsaddupdatesortedlen SystemExitnowatomicEXPIREDr:SKIPPEDStage CLICKHOUSE StageStatusrevokedfailedcontrolrevoke Exceptionexcr"rrrs !!dd.5O$49"    $ $<&    //  MH  Mwzz?)) ;GJJ<{SfRgh ii hug GJJ< !w,,-./g%% &'( '""#$%!"#g::;<=)*+%%,,     ! !  ( ( / /- !((//(/S %%""((**<*<*B*BJDUDUD[D[\&#**11'H1U  ''""((**<*<*B*BJDUDUD[D[\( ''.. !))//1D1D1J1JK/#**11 !))//1D1D1J1JK2"))00 !))//1D1D1J1JK1 $$++ $$++$$,,$$00, kk  ||""CLL$8$89! ??))  (('*;*;*D*DgFWFWF_F_`* 5 ?? LL! !13CDE !24DEF ;< ;< !19=> j9: j9: !19=> (   7o8N7OPQ>uEU?V>WXY?FW@X?YZ[MeTbNcMdefPQVWeQfPghiKERbLcKdef1% 2D1EFG0{1C0DEF*51A+B*CDES]O,-}G Bwi.x=2 F3x=2%&e ,- ) QR Q-hlln[,,44!  OOgjj)00)00661 !!''%  !!''%  ''--(  ''--(  ''--("# %33::$**55 . : : A A(44;;(44;; ll!!&&mvmG F 8    & &w$y & Q qLG HWIXfX ./ *+ fLMWF 8 aKF %gYb6 7 7 8s%7Hc'#c3'c03d8dd