Did I find the right examples for you? yes no

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/process_pool.py   ciel(Download)
import threading
from ciel.runtime.pycurl_rpc import post_string
from ciel.runtime.block_store import is_ref_local
from ciel.public.io_helpers import write_framed_json
from ciel.runtime.producer import write_fixed_ref_string
    def get_reference_for_process(self, record):
        ref = SW2_FixedReference(record.id, self.worker.block_store.netloc)
        if not is_ref_local(ref):
            write_fixed_ref_string(pickle.dumps(record.as_descriptor()), ref)
        return ref