Did I find the right examples for you? yes no

All Samples(5)  |  Call(3)  |  Derive(0)  |  Import(2)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/init.py   ciel(Download)
import pickle
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.executors import spawn_task_helper
from ciel.public.references import SWRealReference
 
        # Some versions of simplejson make these ascii keys into unicode objects :(
        args_dict = dict([(str(k), v) for (k, v) in args_dict.items()])
        initial_task_out_obj = spawn_task_helper(task_record,
                                                 task_private["start_handler"], 
                                                 True,
        else:
            initial_task_out_refs = list(initial_task_out_obj)
        spawn_task_helper(task_record, "sync", True, delegated_outputs = task_descriptor["expected_outputs"], args = {"inputs": initial_task_out_refs}, n_outputs=1)
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
from ciel.runtime.exceptions import BlameUserException, TaskFailedError,\
    MissingInputException, ReferenceUnavailableException
from ciel.runtime.executors import ContextManager,\
    spawn_task_helper, OngoingOutput, package_lookup
import subprocess
            str_args['small_task'] = False
 
        return spawn_task_helper(self.task_record, **str_args)
 
    def tail_spawn(self, request_args):