diff --git a/flow/workflows/drop_flow.go b/flow/workflows/drop_flow.go index decf1b945c..2686cdfaa0 100644 --- a/flow/workflows/drop_flow.go +++ b/flow/workflows/drop_flow.go @@ -16,7 +16,7 @@ func DropFlowWorkflow(ctx workflow.Context, req *protos.ShutdownRequest) error { logger.Info("performing cleanup for flow ", req.FlowJobName) ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ - StartToCloseTimeout: 1 * time.Minute, + StartToCloseTimeout: 5 * time.Minute, }) ctx = workflow.WithValue(ctx, shared.FlowNameKey, req.FlowJobName)