Did I find the right examples for you? yes no

All Samples(2)  |  Call(1)  |  Derive(0)  |  Import(1)

src/c/i/ciel-HEAD/src/python/ciel/runtime/worker/upload_manager.py   ciel(Download)
import ciel
from ciel.runtime.producer import make_local_output
from ciel.runtime.fetcher import sync_retrieve_refs
 
class UploadSession:
    def fetch_refs_deferred(self, session_id, refs):
        ciel.log.error('Fetching session %s' % session_id, 'UPLOAD', logging.DEBUG)
        try:
            sync_retrieve_refs(refs, None)
            self.current_fetches[session_id] = 200