Did I find the right examples for you? yes no

All Samples(8)  |  Call(4)  |  Derive(0)  |  Import(4)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/simple.py   ciel(Download)
from ciel.runtime.object_cache import ref_from_object,\
    retrieve_object_for_ref
from ciel.runtime.fetcher import retrieve_filenames_for_refs, OngoingFetch
from ciel.runtime.producer import make_local_output
 
 
        if self.eager_fetch:
            file_inputs = retrieve_filenames_for_refs(self.input_refs, self.task_record)
        else:
 

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/java.py   ciel(Download)
from ciel.runtime.executors import test_program
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.fetcher import retrieve_filenames_for_refs
import pkg_resources
 
        ciel.engine.publish("worker_event", "Java: fetching JAR")
 
        self.jar_filenames = retrieve_filenames_for_refs(self.jar_refs, self.task_record)
 
    def get_process_args(self):

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/dotnet.py   ciel(Download)
from ciel.runtime.executors import test_program
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.fetcher import retrieve_filenames_for_refs
 
class DotNetExecutor(FilenamesOnStdinExecutor):
        ciel.log.error("Running Dotnet executor for class: %s" % self.class_name, "DOTNET", logging.DEBUG)
        ciel.engine.publish("worker_event", "Dotnet: fetching DLLs")
        self.dll_filenames = retrieve_filenames_for_refs(self.dll_refs, self.task_record)
 
    def get_process_args(self):

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/cso.py   ciel(Download)
from ciel.runtime.executors import test_program
from ciel.runtime.exceptions import BlameUserException
from ciel.runtime.fetcher import retrieve_filenames_for_refs
import logging
 
        ciel.log.error("Running C executor for entry point: %s" % self.entry_point_name, "CEXEC", logging.DEBUG)
        ciel.engine.publish("worker_event", "C-exec: fetching SOs")
        self.so_filenames = retrieve_filenames_for_refs(self.so_refs, self.task_record)
 
    def get_process_args(self):