Did I find the right examples for you? yes no

All Samples(10)  |  Call(3)  |  Derive(0)  |  Import(7)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
import ciel
import os
from ciel.public.references import SW2_ConcreteReference, SW2_SweetheartReference,\
    SW2_FixedReference, SW2_FutureReference, SWErrorReference
import pickle
            ciel.log('Task died with an error', 'PROC', logging.ERROR)
            for output_id in self.expected_outputs:
                task_record.publish_ref(SWErrorReference(output_id, 'RUNTIME_ERROR', self.error_details))
            self.process_pool.delete_process_record(self.process_record)
            return False

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/lazy_task_pool.py   ciel(Download)
from cherrypy.process import plugins
from ciel.runtime.master.job_pool import Job
from ciel.public.references import SW2_FutureReference, \
    SWErrorReference, combine_references, SW2_StreamReference
from ciel.runtime.task import TASK_CREATED, TASK_BLOCKING, TASK_RUNNABLE, \
        if should_notify_outputs:
            for output in task.expected_outputs:
                self._publish_ref(output, SWErrorReference(output, reason, details), task.job)
 
        if worker is not None:

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/job_pool.py   ciel(Download)
import uuid
from ciel.runtime.task_graph import DynamicTaskGraph, TaskGraphUpdate
from ciel.public.references import SWErrorReference
from ciel.runtime.master.scheduling_policy import LocalitySchedulingPolicy,\
    get_scheduling_policy
            for output in task.expected_outputs:
                ciel.log('Publishing error reference for %s (because %s)' % (output, reason), 'TASKFAIL', logging.ERROR)
                self.publish(SWErrorReference(output, reason, details), task)
 
        self.job.schedule()

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/__init__.py   ciel(Download)
from __future__ import with_statement
 
from ciel.public.references import \
    SWRealReference, SW2_FutureReference, SWDataValue, \
    SWErrorReference, SW2_SweetheartReference,\

src/c/i/ciel-HEAD/src/python/ciel/runtime/fetcher.py   ciel(Download)
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 
from ciel.public.references import SW2_ConcreteReference, SW2_StreamReference, SW2_SocketStreamReference,\
    SWDataValue, SWErrorReference, SW2_FixedReference, decode_datavalue,\
    SW2_FetchReference, decode_datavalue_string, encode_datavalue,\

src/c/i/ciel-HEAD/src/python/ciel/runtime/util/start_job.py   ciel(Download)
from ciel.runtime.util.sw_pprint import sw_pprint
 
from ciel.public.references import SWReferenceJSONEncoder,json_decode_object_hook,\
    SW2_FutureReference, SWDataValue, SWErrorReference,\
    SW2_SocketStreamReference, SW2_StreamReference, SW2_ConcreteReference,\

src/c/i/ciel-HEAD/src/python/ciel/runtime/block_store.py   ciel(Download)
# XXX: Hack because urlparse doesn't nicely support custom schemes.
import urlparse
from ciel.public.references import SW2_ConcreteReference, SW2_StreamReference,\
    SW2_FetchReference, SW2_FixedReference, SWRealReference, SWErrorReference,\
    SWDataValue, decode_datavalue