Did I find the right examples for you? yes no

All Samples(4)  |  Call(2)  |  Derive(0)  |  Import(2)

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/multiworker.py   ciel(Download)
from ciel.runtime.exceptions import ReferenceUnavailableException,\
    AbortedException
from ciel.runtime.local_task_graph import LocalTaskGraph, LocalJobOutput
from ciel.runtime.task_executor import TaskExecutionRecord
import Queue
 
        self.reference_cache = {}
        self.task_graph = LocalTaskGraph(worker.execution_features, runnable_queues=self.runnable_queues)
        self.active_or_queued_tasksets = 0
        self.running_tasks = 0

src/c/i/ciel-HEAD/src/python/ciel/runtime/task_executor.py   ciel(Download)
from ciel.runtime.exceptions import ReferenceUnavailableException, MissingInputException,\
    AbortedException
from ciel.runtime.local_task_graph import LocalTaskGraph, LocalJobOutput
from threading import Lock
import logging
        self.reference_cache = dict([(ref.id, ref) for ref in root_task_descriptor["inputs"]])
        self.initial_td = root_task_descriptor
        self.task_graph = LocalTaskGraph(execution_features, [self.initial_td["task_id"]])
        self.job_output = LocalJobOutput(self.initial_td["expected_outputs"])
        for ref in self.initial_td["expected_outputs"]: