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.object_cache import ref_from_object,\
    retrieve_object_for_ref
from ciel.runtime.fetcher import retrieve_filenames_for_refs, OngoingFetch
from ciel.runtime.producer import make_local_output
 
        else:
 
            push_threads = [OngoingFetch(ref, chunk_size=self.stream_chunk_size, task_record=self.task_record, must_block=True) for ref in self.input_refs]
 
            for thread in push_threads:

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
from ciel.public.io_helpers import write_framed_json, read_framed_json
import logging
from ciel.runtime.fetcher import retrieve_filename_for_ref,\
    retrieve_file_or_string_for_ref, OngoingFetch
import datetime
        real_ref = self.task_record.retrieve_ref(ref)
 
        new_fetch = OngoingFetch(real_ref, chunk_size, self.task_record, sole_consumer, make_sweetheart, must_block, can_accept_fd=(fd_socket_name is not None))
        ret = {"sending_fd": False}
        ret_fd = None