Did I find the right examples for you? yes no

All Samples(9)  |  Call(5)  |  Derive(0)  |  Import(4)

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
            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)
        parent_task_record.publish_ref(task_private_ref)
 

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 to_ref(self, refid):
        if self.str is not None:
            ref = ref_from_string(self.str, refid)
        else:
            ref = ref_from_external_file(self.filename, refid)

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
 
    buffer = StringIO()
    encoders[encoder](object, buffer)
    ret = ref_from_string(buffer.getvalue(), id)
    buffer.close()
    return ret

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/worker_view.py   ciel(Download)
import ciel.runtime.executors
import ciel
from ciel.runtime.producer import ref_from_string
 
'''
        elif cherrypy.request.method == 'POST':
            request_body = cherrypy.request.body.read()
            new_ref = ref_from_string(request_body, safe_id)
            if self.backup_sender is not None:
                self.backup_sender.add_data(safe_id, request_body)
    def index(self):
        if cherrypy.request.method == 'POST':
            id = self.block_store.allocate_new_id()
            request_body = cherrypy.request.body.read()
            new_ref = ref_from_string(request_body, id)