Skip to content

Commit

Permalink
Move log line
Browse files Browse the repository at this point in the history
Signed-off-by: Daniel Widdis <[email protected]>
  • Loading branch information
dbwiddis committed Jan 21, 2024
1 parent 09ed85b commit 1914a6b
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -8,20 +8,20 @@
*/
package org.opensearch.flowframework.workflow;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opensearch.action.support.PlainActionFuture;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.threadpool.Scheduler.ScheduledCancellable;
import org.opensearch.threadpool.ThreadPool;
import static org.opensearch.flowframework.common.CommonValue.WORKFLOW_THREAD_POOL;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeoutException;

import static org.opensearch.flowframework.common.CommonValue.WORKFLOW_THREAD_POOL;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opensearch.action.support.PlainActionFuture;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.threadpool.Scheduler.ScheduledCancellable;
import org.opensearch.threadpool.ThreadPool;

/**
* Representation of a process node in a workflow graph.
Expand Down Expand Up @@ -146,13 +146,13 @@ public PlainActionFuture<WorkflowData> execute() {

CompletableFuture.runAsync(() -> {
try {
logger.info("Starting {}.", this.id);
// get the input data from predecessor(s)
Map<String, WorkflowData> inputMap = new HashMap<>();
for (ProcessNode node : predecessors) {
WorkflowData wd = node.future().actionGet();
inputMap.put(wd.getNodeId(), wd);
}
logger.info("Starting {}.", this.id);

ScheduledCancellable delayExec = null;
if (this.nodeTimeout.compareTo(TimeValue.ZERO) > 0) {
Expand Down

0 comments on commit 1914a6b

Please sign in to comment.