Did I find the right examples for you? yes no

All Samples(10)  |  Call(6)  |  Derive(0)  |  Import(4)

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/job_pool.py   ciel(Download)
from cherrypy.process import plugins
from ciel.public.references import SWReferenceJSONEncoder
from ciel.runtime.task import TASK_STATES, TASK_STATE_NAMES, \
    build_taskpool_task_from_descriptor, TASK_QUEUED, TASK_FAILED,\
    TASK_COMMITTED, TASK_QUEUED_STREAMING
                    self.record_task_stats(parent_task, worker)
                    for child in spawned:
                        child_task = build_taskpool_task_from_descriptor(child, parent_task)
                        ciel.log('Task %s spawned task %s' % (parent_id, child_task.task_id), 'SCHED', logging.DEBUG)
                        tx.spawn(child_task)
                task_descriptor['expected_outputs'] = expected_outputs
 
            task = build_taskpool_task_from_descriptor(task_descriptor, None)
            job = Job(job_id, task, job_dir, JOB_CREATED, self, job_options)
            task.job = job

src/c/i/ciel-HEAD/src/python/ciel/runtime/local_task_graph.py   ciel(Download)
 
from ciel.runtime.task_graph import DynamicTaskGraph, TaskGraphUpdate
from ciel.runtime.task import build_taskpool_task_from_descriptor
import Queue
import ciel
        upd = TaskGraphUpdate()
        for spawn in spawns:
            task_object = build_taskpool_task_from_descriptor(spawn, producer_task, taskset)
            upd.spawn(task_object)
        for ref in refs:

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/lazy_task_pool.py   ciel(Download)
from ciel.public.references import SW2_FutureReference, \
    SWErrorReference, combine_references, SW2_StreamReference
from ciel.runtime.task import TASK_CREATED, TASK_BLOCKING, TASK_RUNNABLE, \
    TASK_COMMITTED, build_taskpool_task_from_descriptor, TASK_QUEUED, TASK_FAILED, TASK_QUEUED_STREAMING
from threading import Lock
            task_descriptor['task_id'] = task_id
 
        task = build_taskpool_task_from_descriptor(task_descriptor, parent_task)
        task.job = job
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/recovery.py   ciel(Download)
from ciel.runtime.master.job_pool import RECORD_HEADER_STRUCT,\
    Job, JOB_ACTIVE, JOB_RECOVERED
from ciel.runtime.task import build_taskpool_task_from_descriptor
import ciel
import httplib2
                assert len(root_task_descriptor_string) == root_task_descriptor_length
                root_task_descriptor = simplejson.loads(root_task_descriptor_string, object_hook=json_decode_object_hook)
                root_task = build_taskpool_task_from_descriptor(root_task_descriptor, None)
 
                # FIXME: Get the job pool to create this job, because it has access to the scheduler queue and task failure investigator.
                    task_id = rec['task_id']
                    parent_task = job.task_graph.get_task(rec['parent'])
                    task = build_taskpool_task_from_descriptor(rec, parent_task)
                    task.job = job
                    task.parent.children.append(task)