Did I find the right examples for you? yes no

All Samples(7)  |  Call(3)  |  Derive(0)  |  Import(4)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/simple.py   ciel(Download)
    retrieve_object_for_ref
from ciel.runtime.fetcher import retrieve_filenames_for_refs, OngoingFetch
from ciel.runtime.producer import make_local_output
 
class SimpleExecutor(BaseExecutor):
 
        # 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/worker/upload_manager.py   ciel(Download)
import os
import ciel
from ciel.runtime.producer import make_local_output
from ciel.runtime.fetcher import sync_retrieve_refs
 
    def __init__(self, id, block_store):
        self.id = id
        self.block_store = block_store
        self.current_pos = 0
        self.output_ctx = make_local_output(self.id)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/__init__.py   ciel(Download)
from ciel.runtime.block_store import get_own_netloc, filename_for_ref
 
from ciel.runtime.producer import make_local_output
from ciel.runtime.fetcher import fetch_ref_async
from ciel.runtime.object_cache import retrieve_object_for_ref, ref_from_object,\
    def __init__(self, output_name, output_index, can_smart_subscribe, may_pipe, make_local_sweetheart, can_accept_fd, executor):
        kwargs = {"may_pipe": may_pipe, "can_use_fd": can_accept_fd}
        if can_smart_subscribe:
            kwargs["subscribe_callback"] = self.subscribe_output
        self.output_ctx = make_local_output(output_name, **kwargs)

src/c/i/ciel-HEAD/src/python/ciel/runtime/object_cache.py   ciel(Download)
from ciel.public.references import SWReferenceJSONEncoder, json_decode_object_hook,\
    SWDataValue, encode_datavalue
from ciel.runtime.producer import make_local_output, ref_from_string
from ciel.runtime.fetcher import retrieve_strings_for_refs