Did I find the right examples for you? yes no

All Samples(11)  |  Call(5)  |  Derive(0)  |  Import(6)

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
        if not is_tail_spawn:
            if len(task_descriptor["expected_outputs"]) == 1 and not accept_ref_list_for_single:
                return SW2_FutureReference(task_descriptor["expected_outputs"][0])
            else:
                return [SW2_FutureReference(refid) for refid in task_descriptor["expected_outputs"]]

src/c/i/ciel-HEAD/src/python/ciel/runtime/task_graph.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.public.references import SW2_FutureReference, combine_references,\
    SW2_StreamReference
from ciel.runtime.task import TASK_CREATED, TASK_BLOCKING, TASK_COMMITTED,\
        should_reduce = False
        for output_id in task.expected_outputs:
            ref_table_entry = self.publish(SW2_FutureReference(output_id), task)
            should_reduce = should_reduce or ref_table_entry.has_consumers()
 
                consumer.notify_ref_table_updated(ref_table_entry)
        except KeyError:
            reference = SW2_FutureReference(id)
            ref_table_entry = ReferenceTableEntry(reference, None)
            self.references[reference.id] = ref_table_entry

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/executors/simple.py   ciel(Download)
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
import hashlib
from ciel.public.references import SW2_FutureReference, SWRealReference
import ciel
import logging
            return None
        else:
            return [SW2_FutureReference(x) for x in task_descriptor["expected_outputs"]]
 
    def resolve_required_refs(self, args):

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/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, \