From 3a996e23f38094d5daee505b48faa2c365416214 Mon Sep 17 00:00:00 2001 From: Bowei Xu Date: Mon, 22 Jan 2018 11:33:45 -0800 Subject: [PATCH] protect deleteSingalRequested with condition --- common/persistence/cassandraPersistence.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/common/persistence/cassandraPersistence.go b/common/persistence/cassandraPersistence.go index 4150e9f677b..608427a9619 100644 --- a/common/persistence/cassandraPersistence.go +++ b/common/persistence/cassandraPersistence.go @@ -484,7 +484,8 @@ const ( `and workflow_id = ? ` + `and run_id = ? ` + `and visibility_ts = ? ` + - `and task_id = ? ` + `and task_id = ? ` + + `IF next_event_id = ?` templateGetTransferTasksQuery = `SELECT transfer ` + `FROM executions ` + @@ -2071,7 +2072,8 @@ func (d *cassandraPersistence) updateSignalsRequested(batch *gocql.Batch, signal workflowID, runID, defaultVisibilityTimestamp, - rowTypeExecutionTaskID) + rowTypeExecutionTaskID, + condition) } }