Did I find the right examples for you? yes no

All Samples(12)  |  Call(12)  |  Derive(0)  |  Import(0)

                    def method(*args):
                return
        


src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/__init__.py   ciel(Download)
    def submit_task(self, task_descriptor):
        ciel.engine.publish("worker_event", "Start task " + repr(task_descriptor["task_id"]))
        ciel.engine.publish('execute_task', task_descriptor)
 
    def abort_task(self, task_id):
        ciel.engine.publish("worker_event", "Abort task " + repr(task_id))

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/simple.py   ciel(Download)
            self.output_refs[i] = output.get_completed_ref()
 
        ciel.engine.publish("worker_event", "Executor: Done")
 
    def start_process(self, input_files, output_files):
 
        self.before_execute()
        ciel.engine.publish("worker_event", "Executor: running")
 
        if "go_slow" in self.debug_opts:
                        if message[0] == "C":
                            timestamp = float(message[1:])
                            ciel.engine.publish("worker_event", "Process log %f Computing" % timestamp)
                        elif message[0] == "I":
                            try:
                                params = message[1:].split("|")
                                stream_id = int(params[0])
                                timestamp = float(params[1])
                                ciel.engine.publish("worker_event", "Process log %f Waiting %d" % (timestamp, stream_id))

src/c/i/ciel-HEAD/src/python/ciel/runtime/task_executor.py   ciel(Download)
    def run(self):
        ciel.engine.publish("worker_event", "Start execution " + repr(self.task_descriptor['task_id']) + " with handler " + self.task_descriptor['handler'])
        ciel.log.error("Starting task %s with handler %s" % (str(self.task_descriptor['task_id']), self.task_descriptor['handler']), 'TASK', logging.DEBUG, False)
        try:
            self.start_time = datetime.datetime.now()
            self.success = not self.failed
 
            ciel.engine.publish("worker_event", "Completed execution " + repr(self.task_descriptor['task_id']))
            ciel.log.error("Completed task %s with handler %s" % (str(self.task_descriptor['task_id']), self.task_descriptor['handler']), 'TASK', logging.DEBUG, False)
        except MissingInputException as mie:

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/java.py   ciel(Download)
 
        ciel.log.error("Running Java executor for class: %s" % self.class_name, "JAVA", logging.DEBUG)
        ciel.engine.publish("worker_event", "Java: fetching JAR")
 
        self.jar_filenames = retrieve_filenames_for_refs(self.jar_refs, self.task_record)

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

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