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/executors/simple.py   ciel(Download)
from ciel.runtime.executors.base import BaseExecutor
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.executors import hash_update_with_structure,\
    ContextManager, list_with, add_running_child, remove_running_child
from ciel.runtime.object_cache import ref_from_object,\
    def _execute(self):
        self.context_mgr = ContextManager("Simple Task %s" % self.task_id)
        with self.context_mgr:
            self.guarded_execute()
 

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
    def _run(self, task_private, task_descriptor, task_record):
 
        with ContextManager("Task %s" % task_descriptor["task_id"]) as manager:
            self.context_manager = manager
            self._guarded_run(task_private, task_descriptor, task_record)