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/proc.py   ciel(Download)
import pickle
from ciel.runtime.executors.base import BaseExecutor
from ciel.runtime.producer import write_fixed_ref_string, ref_from_string,\
    ref_from_safe_string
from ciel.runtime.block_store import get_own_netloc
        if is_fixed:
            task_private_ref = SW2_FixedReference(task_private_id, get_own_netloc())
            write_fixed_ref_string(pickle.dumps(task_descriptor["task_private"]), task_private_ref)
        else:
            task_private_ref = ref_from_string(pickle.dumps(task_descriptor["task_private"]), task_private_id)

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/process_pool.py   ciel(Download)
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
 
class ProcessRecord:
    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