Did I find the right examples for you? yes no

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/job_pool.py   ciel(Download)
import time
import uuid
from ciel.runtime.task_graph import DynamicTaskGraph, TaskGraphUpdate
from ciel.public.references import SWErrorReference
from ciel.runtime.master.scheduling_policy import LocalitySchedulingPolicy,\
class JobTaskGraph(DynamicTaskGraph):
 
 
    def __init__(self, job, scheduler_queue):
        DynamicTaskGraph.__init__(self)

src/c/i/ciel-HEAD/src/python/ciel/runtime/local_task_graph.py   ciel(Download)
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 
from ciel.runtime.task_graph import DynamicTaskGraph, TaskGraphUpdate
from ciel.runtime.task import build_taskpool_task_from_descriptor
import Queue
class LocalTaskGraph(DynamicTaskGraph):
 
    def __init__(self, execution_features, runnable_queues):
        DynamicTaskGraph.__init__(self)
        self.root_task_ids = set()