diff --git a/posthog/temporal/workflows/backfill_batch_export.py b/posthog/temporal/workflows/backfill_batch_export.py index 24b00c81876ab..6c0e653cf6a8c 100644 --- a/posthog/temporal/workflows/backfill_batch_export.py +++ b/posthog/temporal/workflows/backfill_batch_export.py @@ -139,12 +139,18 @@ async def backfill_schedule(inputs: BackfillScheduleInputs) -> None: handle = client.get_schedule_handle(inputs.schedule_id) + description = await handle.describe() + jitter = description.schedule.spec.jitter + frequency = dt.timedelta(seconds=inputs.frequency_seconds) full_backfill_range = backfill_range(start_at, end_at, frequency * inputs.buffer_limit) for backfill_start_at, backfill_end_at in full_backfill_range: utcnow = dt.datetime.utcnow() + if jitter is not None: + backfill_end_at = backfill_end_at + jitter + backfill = temporalio.client.ScheduleBackfill( start_at=backfill_start_at, end_at=backfill_end_at,