File tree Expand file tree Collapse file tree
apps/service/src/temporal/workflows Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -14,10 +14,6 @@ export interface PipelineBackfillResult {
1414
1515const BACKFILL_CONTINUE_AS_NEW_THRESHOLD = 200
1616
17- // DEBUG: hard cap on activity iterations per workflow. Remove once the
18- // sheets-destination looping bug is resolved.
19- const DEBUG_MAX_OPERATIONS = 100
20-
2117/**
2218 * Child workflow that runs a backfill from start to finish.
2319 * Calls pipelineSync in a loop until has_more=false, then returns the final eof.
@@ -52,15 +48,6 @@ export async function pipelineBackfill(
5248 return { eof : result . eof }
5349 }
5450
55- if ( operationCount >= DEBUG_MAX_OPERATIONS ) {
56- log . warn ( 'DEBUG_MAX_OPERATIONS reached — stopping backfill early' , {
57- pipelineId,
58- operationCount,
59- has_more : eof . has_more ,
60- } )
61- return { eof }
62- }
63-
6451 if ( operationCount >= BACKFILL_CONTINUE_AS_NEW_THRESHOLD ) {
6552 await continueAsNew < typeof pipelineBackfill > ( pipelineId , { syncState } )
6653 }
You can’t perform that action at this time.
0 commit comments