fix flag in system task worker coordinator

Netflix · Mar 16, 2021 · b0a65f2 · b0a65f2
1 parent 1285af7
commit b0a65f2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/main/java/com/netflix/conductor/core/execution/tasks/SystemTaskWorkerCoordinator.java b/...src/main/java/com/netflix/conductor/core/execution/tasks/SystemTaskWorkerCoordinator.java
@@ -40,7 +40,7 @@
 
 @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
 @Component
-@ConditionalOnProperty(name="conductor.system-task-workers.enabled", havingValue = "true", matchIfMissing = true)
+@ConditionalOnProperty(name = "conductor.system-task-workers.enabled", havingValue = "true", matchIfMissing = true)
 public class SystemTaskWorkerCoordinator extends LifecycleAwareComponent {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(SystemTaskWorkerCoordinator.class);
@@ -117,7 +117,7 @@ private void listen(String queueName) {
     }
 
     private void pollAndExecute(String queueName) {
-        if (isRunning()) {
+        if (!isRunning()) {
             LOGGER.debug("Component stopped. Not polling for system task in queue : {}", queueName);
             return;
         }