Atlas › Test

unspecified_policies_get_defaults

Exact test identity: go.temporal.io/server/common/enums/TestSetDefaultWorkflowIdPolicies/unspecified_policies_get_defaults

Package: go.temporal.io/server/common/enums
Suite / test hierarchy: TestSetDefaultWorkflowIdPolicies/unspecified_policies_get_defaults
Test: unspecified_policies_get_defaults
Introduced at: defaults.go ×1 Frontier kind: Joint frontier
Covered ranges: 7
Covered lines: 13
Covered files: 1

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/enums/defaults.go 13 covered LOC · 7 ranges

Open complete file

  5
  
  )
  
  6
  
  7
  >
  func SetDefaultWorkflowIdReusePolicy(f *enumspb.WorkflowIdReusePolicy) {
  
defaults.go

  8
  >
  	if *f == enumspb.WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED {
  
  9
  >
  		*f = enumspb.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE
  
defaults.go

  10
  >
  	}
  
  11
  
  }
  
  12

  16
  
  	conflictPolicy *enumspb.WorkflowIdConflictPolicy,
  
  17
  
  	defaultConflictPolicy enumspb.WorkflowIdConflictPolicy,
  
  18
  >
  ) {
  
defaults.go

  19
  >
  	// Set default conflict policy, if unset
  
  20
  >
  	if *conflictPolicy == enumspb.WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED {
  
  21
  >
  		//nolint:staticcheck // SA1019: intentional migration of deprecated policy
  
defaults.go

  22
  >
  		if *reusePolicy == enumspb.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING {
  
  23
  
  			// Migrate the deprecated TERMINATE_IF_RUNNING.
  
  24
  
  			*conflictPolicy = enumspb.WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING
  
  25
  
  			*reusePolicy = enumspb.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE
  
  26
  >
  		} else {
  
defaults.go

  27
  >
  			*conflictPolicy = defaultConflictPolicy
  
defaults.go

  28
  >
  		}
  
  29
  
  	}
  
  30
  
  31
  
  	// Set default reuse policy, if unset
  
  32
  >
  	SetDefaultWorkflowIdReusePolicy(reusePolicy)
  
defaults.go

  33
  
  }
  
  34