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/fetcher.py   ciel(Download)
from ciel.runtime.block_store import filename_for_ref, producer_filename,\
    get_own_netloc, create_datavalue_file
from ciel.runtime.producer import get_producer_for_id,\
    ref_from_external_file, ref_from_string
from ciel.runtime.exceptions import ErrorReferenceError,\
    def attach_local_producer(self):
        producer = get_producer_for_id(self.ref.id)
        if producer is None:
            raise PlanFailedError("Plan attach-local-producer failed for %s: not being produced here" % self.ref, "BLOCKSTORE", logging.DEBUG)
        else:

src/c/i/ciel-HEAD/src/python/ciel/runtime/producer_stat.py   ciel(Download)
from ciel.runtime.pycurl_rpc import post_string_noreturn
from ciel.runtime.block_store import filename
from ciel.runtime.producer import get_producer_for_id
 
# Remote endpoints that are receiving adverts from our streaming producers.
def subscribe_output(otherend_netloc, chunk_size, id):
    post = None
    with module_lock:
        try:
            producer = get_producer_for_id(id)

src/c/i/ciel-HEAD/src/python/ciel/runtime/tcp_server.py   ciel(Download)
        self.chunk_size = int(bits[2])
        sock_file.close()
        producer = ciel.runtime.producer.get_producer_for_id(self.refid)
        if producer is None:
            ciel.log("Got auxiliary TCP connection for bad output %s" % self.refid, "TCP_FETCH", logging.WARNING)