class ContinuallyRunProcessorTask implements Callable<Boolean> {

    static boolean isWorkToDo(final ProcessorNode procNode) {
        return procNode.isTriggerWhenEmpty() || !procNode.hasIncomingConnection() || !Connectables.hasNonLoopConnection(procNode) || Connectables.flowFilesQueued(procNode);
    }

    public  ContinuallyRunProcessorTask(final SchedulingAgent schedulingAgent, final ProcessorNode procNode,
            final FlowController flowController, final ProcessContextFactory contextFactory, final ScheduleState scheduleState,
            final StandardProcessContext processContext);

}