Problem on localOnly queue sharding strategy

[sarmuru2]

When conductor.redis.queueShardingStrategy=localOnly is set, deciderQueue is created for each pod. But we have multiple conductor pods in kubernetes. When we send the COMPLETED task update request to conductor, kubernetes load balances update task request to any of the conductor pod. decide() is invoked inside updateStatus() hence decide() is invoked for a workflow in any of the conductor pod. At the same time sweeper also can invoke decide() method from a specific pod. Which means localOnly strategy will not work in this case. Is there any solution for this problem? We cannot use redis execution lock as we are having master to master replication of redis nodes.