Did I find the right examples for you? yes no

All Samples(5)  |  Call(2)  |  Derive(0)  |  Import(3)

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/proc.py   ciel(Download)
    spawn_task_helper, OngoingOutput, package_lookup
import subprocess
from ciel.public.io_helpers import write_framed_json, read_framed_json
import logging
from ciel.runtime.fetcher import retrieve_filename_for_ref,\
    def json_event_loop(self, reader, writer):
        while True:
 
            try:
                (method, args) = read_framed_json(reader)

src/c/i/ciel-HEAD/src/python/ciel/public/rpc_helper.py   ciel(Download)
import select
import sys
from ciel.public.io_helpers import read_framed_json, write_framed_json
 
class ShutdownException(Exception):
            have_message = self.in_fd in reads
            if have_message:
                (method, args) = read_framed_json(self.in_fp)
                if method == "subscribe" or method == "unsubscribe":
                    if self.active_outputs is None:

src/c/i/ciel-HEAD/src/python/ciel/runtime/executors/__init__.py   ciel(Download)
    SW2_FixedReference, SWReferenceJSONEncoder, SW2_ConcreteReference,\
    decode_datavalue_string, encode_datavalue, SW2_TombstoneReference
from ciel.public.io_helpers import read_framed_json, write_framed_json
from ciel.runtime.exceptions import BlameUserException, ReferenceUnavailableException,\
    MissingInputException, TaskFailedError