Skip to content
This repository was archived by the owner on Dec 13, 2023. It is now read-only.

Commit 58125a2

Browse files
authored
Fix isolated task queue polling (#2848)
1 parent a377b5e commit 58125a2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/java/com/netflix/conductor/core/execution/tasks/IsolatedTaskQueueProducer.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public IsolatedTaskQueueProducer(
5858
@Value("${conductor.app.isolatedSystemTaskEnabled:false}")
5959
boolean isolatedSystemTaskEnabled,
6060
@Value("${conductor.app.isolatedSystemTaskQueuePollInterval:10s}")
61-
Duration isolatedSystemTaskQueuePollIntervalSecs) {
61+
Duration isolatedSystemTaskQueuePollInterval) {
6262

6363
this.metadataService = metadataService;
6464
this.asyncSystemTasks = asyncSystemTasks;
@@ -71,8 +71,8 @@ public IsolatedTaskQueueProducer(
7171
.scheduleWithFixedDelay(
7272
this::addTaskQueues,
7373
1000,
74-
isolatedSystemTaskQueuePollIntervalSecs.getSeconds(),
75-
TimeUnit.SECONDS);
74+
isolatedSystemTaskQueuePollInterval.toMillis(),
75+
TimeUnit.MILLISECONDS);
7676
} else {
7777
LOGGER.info("Isolated System Task Worker DISABLED");
7878
}

0 commit comments

Comments
 (0)