Vihren Atlas

transfer_queue_active_task_executor.go ×4

Code frontier

unlabeled · c_c35f9fe69d81

5 tests · 9211 LOC · 261 files · introduces 0 tests · 14 LOC · 2 files

Introduces — evidence that enters the hierarchy at this concept

Code
5 ranges14 lines · 2 files
Tests
0 tests

Contains — complete concept membership

All code (extent)
1953 ranges9211 lines · 261 files · Browse complete extent
All tests (intent)
5 testsBrowse complete intent

Neighbourhood graph

The orange circle is the focus. Violet and green circles are every ancestor and descendant, broader and narrower, at any distance; blue squares and pink diamonds are the introduced files and exact introduced tests of every visible concept, not only the focus's. Arrows point from broader to narrower concepts and bridge only concepts omitted from this view. Undirected links show source or test introduction. Concept and file size follows LOC; exact test nodes use test-count units.

Introduced files, introduced tests, and structurally relevant concept specialization

In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the native relationship evidence on this page.

Graph controls are ready.

Interactive rendering requires JavaScript and WebGL. Use the native relationship evidence on this page while the interactive map is unavailable.

Native relationship evidence

Every exact file and test below is linked only from the concept that introduces it.

Introduced tests

Every collected test enters the hierarchy at exactly one concept.

No tests are introduced at this concept. Its intent tests are introduced by other concepts.

Introduced code

Every collected source range enters the hierarchy at exactly one concept.

2 files ranked by introduced lines: 14 introduced LOC across 5 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/service/history/transfer_queue_active_task_executor.go 12 introduced LOC · 4 ranges

Open complete file

965 // If a VersioningOverride is present at child workflow start, it takes precedence over inherited information.
966 if versioningOverride == nil {
967 > if attributes.InheritBuildId && mutableState.GetEffectiveVersioningBehavior() == enumspb.VERSIONING_BEHAVIOR_UNSPECIFIED { //nolint:staticcheck // SA1019: worker versioning v0.2 transfer_queue_active_task_executor.go
968 // Do not set inheritedBuildId for v3 wfs.
969 // setting inheritedBuildId of the child wf to the assignedBuildId of the parent
982 // If this is a cross-TQ child, we don't want to ask matching the same question twice, so we re-use the result from
983 // the first matching task-queue-in-version check.
984 > newTQInPinnedVersion := false transfer_queue_active_task_executor.go
985 >
986 > // Child of pinned parent will inherit the parent's version if the Child's Task Queue belongs to that version.
987 > if mutableState.GetEffectiveVersioningBehavior() == enumspb.VERSIONING_BEHAVIOR_PINNED {
988 inheritedPinnedVersion = worker_versioning.ExternalWorkerDeploymentVersionFromDeployment(mutableState.GetEffectiveDeployment())
989 newTQ := attributes.GetTaskQueue().GetName()
1002
1003 // Pinned and one-time overrides are inherited if Task Queue of new run is compatible with the override version.
1004 > if o := mutableState.GetExecutionInfo().GetVersioningInfo().GetVersioningOverride(); worker_versioning.GetOverrideTargetDeploymentVersion(o) != nil { transfer_queue_active_task_executor.go
1005 inheritedVersioningOverride = o
1006 newTQ := attributes.GetTaskQueue().GetName()
1012
1013 // If the parent has AutoUpgrade behavior, we populate the inherited auto upgrade info based on whether the child TQ is in the same deployment version as the parent TQ.
1014 > sourceDeploymentVersion := worker_versioning.ExternalWorkerDeploymentVersionFromDeployment(mutableState.GetEffectiveDeployment()) transfer_queue_active_task_executor.go
1015 > sourceDeploymentRevisionNumber := mutableState.GetVersioningRevisionNumber()
1016 >
1017 > // Only set inherited auto upgrade info if source deployment version and revision number are not nil
1018 > if sourceDeploymentVersion != nil && sourceDeploymentRevisionNumber != 0 &&
1019 > mutableState.GetEffectiveVersioningBehavior() == enumspb.VERSIONING_BEHAVIOR_AUTO_UPGRADE {
1020 inheritedAutoUpgradeInfo = &deploymentpb.InheritedAutoUpgradeInfo{
1021 SourceDeploymentVersion: sourceDeploymentVersion,
go.temporal.io/server/common/worker_versioning/worker_versioning.go 2 introduced LOC · 1 range

Open complete file

674 }
675
676 > func GetOverrideTargetDeploymentVersion(override *workflowpb.VersioningOverride) *deploymentpb.WorkerDeploymentVersion { worker_versioning.go
677 > switch o := override.GetOverride().(type) {
678 case *workflowpb.VersioningOverride_Pinned:
679 return GetOverridePinnedVersion(override)

Direct hierarchy

Parents

Children