Did I find the right examples for you? yes no

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/producer.py   ciel(Download)
from ciel.runtime.block_store import get_own_netloc, producer_filename,\
    filename_for_ref
from ciel.public.references import SWDataValue, encode_datavalue, SW2_ConcreteReference, \
    SW2_StreamReference, SW2_CompletedReference, SW2_SocketStreamReference,\
    decode_datavalue_string
        if self.current_size < 1024:
            with open(completed_file, "r") as fp:
                return SWDataValue(self.refid, encode_datavalue(fp.read()))
        else:
            return SW2_ConcreteReference(self.refid, size_hint=self.current_size, location_hints=[get_own_netloc()])
def ref_from_string(string, id):
    if len(string) < 1024:
        return SWDataValue(id, value=encode_datavalue(string))
    else:
        output_ctx = make_local_output(id)
def ref_from_safe_string(string, id):
    if len(string) < 1024:
        return SWDataValue(id, value=string)
    else:
        return ref_from_string(decode_datavalue_string(string), id)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/grab.py   ciel(Download)
import ciel
import logging
from ciel.public.references import SWReferenceJSONEncoder, SWDataValue
import simplejson
from ciel.runtime.executors.simple import SimpleExecutor
            out_str = simplejson.dumps(ref, cls=SWReferenceJSONEncoder)
            cache_object(ref, "json", self.output_ids[i])
            self.output_refs[i] = SWDataValue(self.output_ids[i], out_str)
 
        ciel.log.error('Done fetching URLs', 'FETCHEXECUTOR', logging.DEBUG)

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/object_cache.py   ciel(Download)
 
import pickle
import simplejson
from cStringIO import StringIO
from ciel.public.references import SWReferenceJSONEncoder, json_decode_object_hook,\

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/cluster_view.py   ciel(Download)
import cherrypy
import time
from ciel.public.references import SWDataValue, decode_datavalue
 
def table_row(key, *args):