protect deleteSingalRequested with condition

cadence-workflow · Jan 22, 2018 · 3a996e2 · 3a996e2
1 parent f29dec1
commit 3a996e2
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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)
 	}
 }