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/base.py   ciel(Download)
import ciel
import logging
from ciel.runtime.object_cache import retrieve_object_for_ref,\
    ref_from_object
 
    def build_task_descriptor(cls, task_descriptor, parent_task_record):
        # Convert task_private to a reference in here. 
        task_private_id = ("%s:_private" % task_descriptor["task_id"])
        task_private_ref = ref_from_object(task_descriptor["task_private"], BaseExecutor.TASK_PRIVATE_ENCODING, task_private_id)
        parent_task_record.publish_ref(task_private_ref)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/sync.py   ciel(Download)
# ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
from ciel.runtime.object_cache import ref_from_object
from ciel.runtime.executors.simple import SimpleExecutor
from ciel.runtime.exceptions import BlameUserException
    def _execute(self):
        reflist = [self.task_record.retrieve_ref(x) for x in self.args["inputs"]]
        self.output_refs[0] = ref_from_object(reflist, "json", self.output_ids[0])
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/simple.py   ciel(Download)
from ciel.runtime.executors import hash_update_with_structure,\
    ContextManager, list_with, add_running_child, remove_running_child
from ciel.runtime.object_cache import ref_from_object,\
    retrieve_object_for_ref
from ciel.runtime.fetcher import retrieve_filenames_for_refs, OngoingFetch
        # Add the args dict
        args_name = "%ssimple_exec_args" % name_prefix
        args_ref = ref_from_object(args, "pickle", args_name)
        parent_task_record.publish_ref(args_ref)
        task_descriptor["dependencies"].append(args_ref)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/__init__.py   ciel(Download)
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,\
    cache_object