479
func (d *VersionWorkflowRunner) startDrainage(ctx workflow.Context) {
480
if d.VersionState.GetDrainageInfo().GetStatus() == enumspb.VERSION_DRAINAGE_STATUS_UNSPECIFIED {
482
>
d.VersionState.DrainageInfo = &deploymentpb.VersionDrainageInfo{
483
>
Status: enumspb.VERSION_DRAINAGE_STATUS_DRAINING,
484
>
LastChangedTime: now,
485
>
LastCheckedTime: now,
486
>
}
487
>
if workflow.GetVersion(ctx, "no-draining-signal", workflow.DefaultVersion, 1) == workflow.DefaultVersion {
488
// this is not needed because startDrainage is called only from syncVersionState which sends the summary back to deployment.
489
// TODO: cleanup with sync mode
490
d.syncSummary(ctx)
491
}
493
}
494
}