Did I find the right examples for you? yes no

All Samples(9)  |  Call(1)  |  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
    def get_stream_ref(self):
        if ciel.runtime.tcp_server.tcp_server_active():
            return SW2_SocketStreamReference(self.refid, get_own_netloc(), ciel.runtime.tcp_server.aux_listen_port)
        else:
            return SW2_StreamReference(self.refid, location_hints=[get_own_netloc()])

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/master/scheduling_policy.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_SweetheartReference, SW2_ConcreteReference,\
    SW2_StreamReference
import random

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

src/c/i/ciel-HEAD/src/python/ciel/runtime/task.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_StreamReference, SW2_FixedReference
import datetime
import time