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,\
 
        # TODO: Make these use OngoingOutputs and the context manager.                
        with list_with([make_local_output(id, may_pipe=self.pipe_output) for id in self.output_ids]) as out_file_contexts:
 
            if self.stream_output:

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/stdinout.py   ciel(Download)
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.fetcher import retrieve_filename_for_ref
from ciel.runtime.executors import list_with
 
class SWStdinoutExecutor(ProcessRunningExecutor):
    def await_process(self, input_files, output_files):
 
        with list_with([open(filename, 'r') for filename in input_files]) as fileobjs:
            for fileobj in fileobjs:
                try: