class PipelineNodeImpl extends BluePipelineNode {

    protected static WorkflowRun getRun(WorkflowJob job, long itemId) throws InterruptedException {
        WorkflowRun restartRun = QueueUtil.getRun(job, itemId);
        if (restartRun == null) {
            long startTimeMs = System.currentTimeMillis();
            while (restartRun == null && System.currentTimeMillis()-startTimeMs < waitJobInqueueTimeout) {
                Thread.sleep(100);
                restartRun = QueueUtil.getRun(job, itemId);
            }
        }
        return restartRun;
    }

    public  PipelineNodeImpl(FlowNodeWrapper node, Reachable parent, WorkflowRun run);

}