diff --git a/posthog/temporal/data_imports/external_data_job.py b/posthog/temporal/data_imports/external_data_job.py index 26f6b5cf2ca07..4a76d5376fc52 100644 --- a/posthog/temporal/data_imports/external_data_job.py +++ b/posthog/temporal/data_imports/external_data_job.py @@ -177,6 +177,8 @@ async def run_external_data_job(inputs: ExternalDataJobInputs) -> TSchemaTables: stripe_secret_key = model.pipeline.job_inputs.get("stripe_secret_key", None) account_id = model.pipeline.job_inputs.get("stripe_account_id", None) + # Cludge: account_id should be checked here too but can deal with nulls + # until we require re update of account_ids in stripe so they're all store if not stripe_secret_key: raise ValueError(f"Stripe secret key not found for job {model.id}") source = stripe_source(