Did I find the right examples for you? yes no

All Samples(6)  |  Call(3)  |  Derive(0)  |  Import(3)

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,\
    def _report_tasks(self, report, toplevel_task, worker):
        with self._lock:
 
            tx = TaskGraphUpdate()
 

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
            producer_task = self.get_task(producer["task_id"])
            taskset = producer_task.taskset
        upd = TaskGraphUpdate()
        for spawn in spawns:
            task_object = build_taskpool_task_from_descriptor(spawn, producer_task, taskset)

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/master_view.py   ciel(Download)
import logging
import socket
from ciel.runtime.task_graph import TaskGraphUpdate
 
class MasterRoot:
            refs = simplejson.loads(request_body, object_hook=json_decode_object_hook)
 
            tx = TaskGraphUpdate()
            for ref in refs:
                tx.publish(ref, task)