remove search attributes

PeerDB-io · Nov 24, 2023 · 89bbca2 · 89bbca2
1 parent 0fd28a0
commit 89bbca2
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 19 deletions.
diff --git a/flow/cmd/handler.go b/flow/cmd/handler.go
@@ -309,9 +309,6 @@ func (h *FlowRequestHandler) ShutdownFlow(
 	workflowOptions := client.StartWorkflowOptions{
 		ID:        workflowID,
 		TaskQueue: shared.PeerFlowTaskQueue,
-		SearchAttributes: map[string]interface{}{
-			"MirrorName": req.FlowJobName,
-		},
 	}
 	dropFlowHandle, err := h.temporalClient.ExecuteWorkflow(
 		ctx,                       // context

diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -189,10 +189,6 @@ func CDCFlowWorkflowWithConfig(
 			}
 		}
 
-		searchAttributes := map[string]interface{}{
-			"MirrorName": cfg.FlowJobName,
-		}
-
 		// start the SetupFlow workflow as a child workflow, and wait for it to complete
 		// it should return the table schema for the source peer
 		setupFlowID, err := GetChildWorkflowID(ctx, "setup-flow", cfg.FlowJobName)
@@ -205,7 +201,6 @@ func CDCFlowWorkflowWithConfig(
 			RetryPolicy: &temporal.RetryPolicy{
 				MaximumAttempts: 20,
 			},
-			SearchAttributes: searchAttributes,
 		}
 		setupFlowCtx := workflow.WithChildOptions(ctx, childSetupFlowOpts)
 		setupFlowFuture := workflow.ExecuteChildWorkflow(setupFlowCtx, SetupFlowWorkflow, cfg)
@@ -225,8 +220,7 @@ func CDCFlowWorkflowWithConfig(
 			RetryPolicy: &temporal.RetryPolicy{
 				MaximumAttempts: 20,
 			},
-			TaskQueue:        shared.SnapshotFlowTaskQueue,
-			SearchAttributes: searchAttributes,
+			TaskQueue: shared.SnapshotFlowTaskQueue,
 		}
 		snapshotFlowCtx := workflow.WithChildOptions(ctx, childSnapshotFlowOpts)
 		snapshotFlowFuture := workflow.ExecuteChildWorkflow(snapshotFlowCtx, SnapshotFlowWorkflow, cfg)
@@ -323,18 +317,13 @@ func CDCFlowWorkflowWithConfig(
 			return state, err
 		}
 
-		searchAttributes := map[string]interface{}{
-			"MirrorName": cfg.FlowJobName,
-		}
-
 		// execute the sync flow as a child workflow
 		childSyncFlowOpts := workflow.ChildWorkflowOptions{
 			WorkflowID:        syncFlowID,
 			ParentClosePolicy: enums.PARENT_CLOSE_POLICY_REQUEST_CANCEL,
 			RetryPolicy: &temporal.RetryPolicy{
 				MaximumAttempts: 20,
 			},
-			SearchAttributes: searchAttributes,
 		}
 		ctx = workflow.WithChildOptions(ctx, childSyncFlowOpts)
 		syncFlowOptions.RelationMessageMapping = *state.RelationMessageMapping
@@ -367,7 +356,6 @@ func CDCFlowWorkflowWithConfig(
 			RetryPolicy: &temporal.RetryPolicy{
 				MaximumAttempts: 20,
 			},
-			SearchAttributes: searchAttributes,
 		}
 		ctx = workflow.WithChildOptions(ctx, childNormalizeFlowOpts)
 

diff --git a/flow/workflows/qrep_flow.go b/flow/workflows/qrep_flow.go
@@ -206,9 +206,6 @@ func (q *QRepFlowExecution) startChildWorkflow(
 		RetryPolicy: &temporal.RetryPolicy{
 			MaximumAttempts: 20,
 		},
-		SearchAttributes: map[string]interface{}{
-			"MirrorName": q.config.FlowJobName,
-		},
 	})
 
 	future := workflow.ExecuteChildWorkflow(