appyter.ext package

Subpackages

• appyter.ext.asyncio package
  • Submodules
  • appyter.ext.asyncio.event_emitter module
    • EventEmitter
      • EventEmitter.clear()
      • EventEmitter.emit()
      • EventEmitter.flush()
      • EventEmitter.off()
      • EventEmitter.on()
      • EventEmitter.remove()
      • EventEmitter.wait()
  • appyter.ext.asyncio.event_loop module
    • EventLoopThread
      • EventLoopThread.run()
      • EventLoopThread.stop()
    • SharedEventLoopThreadPoolExecutor
    • get_event_loop()
    • new_event_loop()
    • with_event_loop()
  • appyter.ext.asyncio.helpers module
    • anext()
    • awaitable_identity()
    • ensure_async()
    • ensure_async_contextmanager()
    • ensure_async_func()
    • ensure_async_generator()
    • ensure_async_literal()
    • ensure_async_wrapper()
    • ensure_sync()
    • ensure_sync_contextmanager()
    • ensure_sync_coro()
    • ensure_sync_generator()
    • ensure_sync_wrapper()
    • isasynccontextmanager()
    • iscontextmanager()
  • appyter.ext.asyncio.subprocess module
    • ensure_terminated()
    • sh()
    • stream_readline_to_queue()
  • appyter.ext.asyncio.test_helpers module
  • appyter.ext.asyncio.test_subprocess module
    • test_subprocess()
  • appyter.ext.asyncio.try_n_times module
    • async_try_n_times()
    • try_n_times()
  • Module contents
• appyter.ext.click package
  • Module contents
    • Json
      • Json.convert()
      • Json.name
      • Json.split_envvar_value()
    • click_argument_setenv()
    • click_option_setenv()
• appyter.ext.fsspec package
  • Subpackages
    • appyter.ext.fsspec.spec package
      • Submodules
      • appyter.ext.fsspec.spec.composable module
      • appyter.ext.fsspec.spec.mountable module
      • appyter.ext.fsspec.spec.sync_async module
      • Module contents
  • Submodules
  • appyter.ext.fsspec.chroot module
    • ChrootFileSystem
      • ChrootFileSystem.cat_file()
      • ChrootFileSystem.copy()
      • ChrootFileSystem.cp_file()
      • ChrootFileSystem.exists()
      • ChrootFileSystem.get_drs()
      • ChrootFileSystem.get_file()
      • ChrootFileSystem.info()
      • ChrootFileSystem.ls()
      • ChrootFileSystem.makedirs()
      • ChrootFileSystem.mkdir()
      • ChrootFileSystem.mount()
      • ChrootFileSystem.mv()
      • ChrootFileSystem.protocol
      • ChrootFileSystem.put_file()
      • ChrootFileSystem.rm()
      • ChrootFileSystem.rm_file()
      • ChrootFileSystem.rmdir()
      • ChrootFileSystem.root_marker
  • appyter.ext.fsspec.core module
    • url_to_chroot_fs()
    • url_to_fs_ex()
  • appyter.ext.fsspec.drs module
    • DRSFileSystem
      • DRSFileSystem.protocol
  • appyter.ext.fsspec.fuse module
    • fs_mount()
  • appyter.ext.fsspec.mapperfs module
    • MapperFileSystem
      • MapperFileSystem.cat_file()
      • MapperFileSystem.copy()
      • MapperFileSystem.exists()
      • MapperFileSystem.from_json()
      • MapperFileSystem.get_drs()
      • MapperFileSystem.info()
      • MapperFileSystem.ls()
      • MapperFileSystem.makedirs()
      • MapperFileSystem.mkdir()
      • MapperFileSystem.mv()
      • MapperFileSystem.protocol
      • MapperFileSystem.rm()
      • MapperFileSystem.rm_file()
      • MapperFileSystem.rmdir()
      • MapperFileSystem.root_marker
      • MapperFileSystem.to_json()
  • appyter.ext.fsspec.overlayfs module
    • OverlayFileSystem
      • OverlayFileSystem.cat_file()
      • OverlayFileSystem.copy()
      • OverlayFileSystem.cp_file()
      • OverlayFileSystem.exists()
      • OverlayFileSystem.get_drs()
      • OverlayFileSystem.get_file()
      • OverlayFileSystem.info()
      • OverlayFileSystem.ls()
      • OverlayFileSystem.makedirs()
      • OverlayFileSystem.mkdir()
      • OverlayFileSystem.mount()
      • OverlayFileSystem.mv()
      • OverlayFileSystem.protocol
      • OverlayFileSystem.put_file()
      • OverlayFileSystem.rm()
      • OverlayFileSystem.rm_file()
      • OverlayFileSystem.rmdir()
      • OverlayFileSystem.root_marker
  • appyter.ext.fsspec.s3fs module
  • appyter.ext.fsspec.sbfs module
    • SBFSBufferedFile
    • SBFSFileSystem
      • SBFSFileSystem.CHUNK_SIZE
      • SBFSFileSystem.get_drs()
  • appyter.ext.fsspec.singleton module
    • SingletonFileSystem
      • SingletonFileSystem.root_marker
  • appyter.ext.fsspec.storage module
    • ensure_storage()
  • appyter.ext.fsspec.test_chroot module
  • appyter.ext.fsspec.test_drs module
  • appyter.ext.fsspec.test_fuse module
  • appyter.ext.fsspec.test_fuseless_mount module
  • appyter.ext.fsspec.test_mapperfs module
  • appyter.ext.fsspec.test_overlayfs module
  • appyter.ext.fsspec.test_pathmap module
  • appyter.ext.fsspec.test_sbfs module
  • appyter.ext.fsspec.util module
    • fsspec_cp()
    • fsspec_read_and_run()
  • appyter.ext.fsspec.writecache module
    • LocalTempFile
      • LocalTempFile.cleanup()
      • LocalTempFile.close()
      • LocalTempFile.commit()
      • LocalTempFile.discard()
    • WriteCacheFileSystem
      • WriteCacheFileSystem.cat_file()
      • WriteCacheFileSystem.copy()
      • WriteCacheFileSystem.cp_file()
      • WriteCacheFileSystem.exists()
      • WriteCacheFileSystem.get_drs()
      • WriteCacheFileSystem.get_file()
      • WriteCacheFileSystem.info()
      • WriteCacheFileSystem.ls()
      • WriteCacheFileSystem.makedirs()
      • WriteCacheFileSystem.mkdir()
      • WriteCacheFileSystem.mount()
      • WriteCacheFileSystem.mv()
      • WriteCacheFileSystem.protocol
      • WriteCacheFileSystem.put_file()
      • WriteCacheFileSystem.rm()
      • WriteCacheFileSystem.rm_file()
      • WriteCacheFileSystem.rmdir()
  • Module contents
• appyter.ext.nbclient package
  • Module contents
    • NotebookClientIOPubHook
      • NotebookClientIOPubHook.async_execute_cell()
      • NotebookClientIOPubHook.async_setup_kernel()
      • NotebookClientIOPubHook.handle_comm_msg()
      • NotebookClientIOPubHook.process_message()
• appyter.ext.pathlib package
  • Submodules
  • appyter.ext.pathlib.chroot module
    • ChrootPurePosixPath
      • ChrootPurePosixPath.join()
      • ChrootPurePosixPath.realpath()
      • ChrootPurePosixPath.relative_to()
  • Module contents
    • is_relative_to()
• appyter.ext.socketio package
  • Submodules
  • appyter.ext.socketio.chunked_emit module
    • ChunkedEmitMixin
      • ChunkedEmitMixin.CHUNK_SIZE
      • ChunkedEmitMixin.emit()
  • appyter.ext.socketio.client module
    • AsyncClient
      • AsyncClient.connect()
  • appyter.ext.socketio.forwarding module
    • ForwardingMixin
      • ForwardingMixin.emit()
  • appyter.ext.socketio.priority_queued_emit module
    • PriorityQueuedEmitMixin
      • PriorityQueuedEmitMixin.disconnect()
      • PriorityQueuedEmitMixin.emit()
  • appyter.ext.socketio.server module
    • AsyncServer
      • AsyncServer.forward()
      • AsyncServer.on()
  • Module contents
• appyter.ext.watchgod package
  • Submodules
  • appyter.ext.watchgod.watcher module
    • GlobWatcher
      • GlobWatcher.should_watch_dir()
      • GlobWatcher.should_watch_file()
  • Module contents

Submodules

appyter.ext.aiohttp module

appyter.ext.aiohttp.run_app(app, host='127.0.0.1', port=5000, path=None)

appyter.ext.aiohttp.with_app_running(app, host='127.0.0.1', port=5000, path=None, ssl_context=None)

appyter.ext.contextlib module

class appyter.ext.contextlib.ContextManagerAsHandle(inner)

Bases: object

close()

open()

appyter.ext.contextlib.ensure_context(obj)

appyter.ext.contextlib.with_many(**withables)

appyter.ext.cryptography module

appyter.ext.cryptography.adhoc_ssl_context(cn: str | None = None, protocol: int | None = None)

From https://github.com/pallets/werkzeug/blob/main/src/werkzeug/serving.py Produces an adhoc SSL cert and returns an SSL context for https in development.

appyter.ext.dict module

appyter.ext.dict.dict_collision_free_update(d, **kwargs)

appyter.ext.dict.dict_filter_none(d)

appyter.ext.dict.dict_flatten(d)

appyter.ext.dict.dict_merge(d, **kwargs)

appyter.ext.dict.dict_typed_flatten(d)

dict_flatten but preserves lists & ordering

appyter.ext.dict.dict_typed_unflatten(f)

opposite of dict_typed_unflatten

appyter.ext.dict.dict_unflatten(f)

appyter.ext.dict.expand_dotmap(dotmap)

Convert dot-notation into deep dict

appyter.ext.drs module

appyter.ext.drs.ensure_drs(url)

Ensures a url is accessible via DRS

appyter.ext.emitter module

appyter.ext.emitter.json_emitter_factory(output)

appyter.ext.emitter.url_to_emitter(url)

appyter.ext.exceptions module

appyter.ext.exceptions.exception_as_dict(exc)

appyter.ext.flask module

appyter.ext.flask.decorator_in_production(production_decorator)

appyter.ext.flask.is_remote(url)

appyter.ext.flask.join_routes(*routes)

Utility function for joining routes while striping extraneous slashes

appyter.ext.flask.request_get(request, key, default=None)

appyter.ext.flask.route_join_with_or_without_slash(blueprint, *routes, **kwargs)

Like @app.route but doesn’t care about trailing slash or not

appyter.ext.flask.secure_filepath(filepath)

Ensures this will be a sanitized relative path

appyter.ext.flask.secure_url(url)

appyter.ext.functools module

appyter.ext.functools.ensure_callable(var)

appyter.ext.functools.memcached(func)

Cache all calls to this function in memory permanently

appyter.ext.hashlib module

appyter.ext.hashlib.hashsum_dict(algo, obj)

appyter.ext.hashlib.hashsum_io(algo, io, chunk_size=65536)

appyter.ext.hashlib.hashsum_str(algo, obj)

appyter.ext.hashlib.sha1sum_dict(obj)

appyter.ext.hashlib.sha1sum_io(io, chunk_size=65536)

appyter.ext.hashlib.sha1sum_str(obj)

appyter.ext.importlib module

appyter.ext.importlib.importdir(_dirname_, _package_, _globals_)

appyter.ext.importlib.importdir_deep(_dirname_, _package_, _globals_, filter_mod=<function <lambda>>)

appyter.ext.io module

async appyter.ext.io.async_copyfileobj(fsrc, fdst, length=0)

Async version of shutil.copyfileobj

appyter.ext.itertools module

async appyter.ext.itertools.alist(agen)

Resolve all values from an asynchronous generator like it was an iterator

appyter.ext.itertools.collapse(L)

appyter.ext.itertools.ensure_list(L)

appyter.ext.itertools.one_and_only(it)

appyter.ext.json module

appyter.ext.json.try_json_dumps(v)

appyter.ext.json.try_json_loads(v)

appyter.ext.multiprocessing module

appyter.ext.pytest module

appyter.ext.pytest.assert_eq(a, b)

appyter.ext.pytest.assert_exc(ExpectedException)

appyter.ext.pytest.http_serve_ctx(directory, port=8888)

Context for _http_serve, ensuring server is ready before proceeding

appyter.ext.re module

appyter.ext.re.re_full(expr)

appyter.ext.re.slugify(s)

appyter.ext.subprocess module

appyter.ext.subprocess.interrupt(proc: Process)

appyter.ext.tempfile module

appyter.ext.tempfile.mktemp(suffix='', prefix='appyter-tmp', dir=None)

Same as tempfile.mktemp but with appyter prefix

appyter.ext.tempfile.tempdir(path=None)

A context for a temporary directory that may exist, if it doesn’t we’ll use mkdtemp. Also has a safety mechanism when dealing with mounts – it will not rmtree if the directory is a mounted directory (since this might remove files unintentially).

appyter.ext.urllib module

class appyter.ext.urllib.URI(url=None, scheme=None, username=None, password=None, hostname=None, port=None, path=None, query_string=None, fragment=None)

Bases: object

Not unlike yarl’s URL class but - support for :: notation as used in fsspec URIs - posix_path path operation - fragment parsing - dotmap support (query_ex)

property auth

property authority

fragment: str | None

fragment_join(*parts)

property fragment_name

property fragment_parent

property fragment_path

property fragment_posix_path

property fragment_query

property fragment_query_ex

property fragment_query_string

hostname: str | None

join(*parts)

property name

property netloc

property parent

password: str | None

path: str

port: int | None

property posix_path

property query

property query_ex

query_string: str | None

scheme: str | None

update_fragment_query(fragment_query)

update_query(query)

username: str | None

with_fragment(fragment)

with_fragment_path(fragment_path)

with_fragment_query(fragment_query)

with_fragment_query_string(fragment_query_string)

with_hostname(hostname)

with_password(password)

with_path(path)

with_port(port)

with_query(query)

with_query_string(query_string)

with_scheme(scheme)

with_username(username)

appyter.ext.urllib.join_slash(*parts)

appyter.ext.urllib.join_url(root, *parts)

appyter.ext.urllib.parent_url(url)

appyter.ext.urllib.parse_qs_values(query_map)

appyter.ext.urllib.url_filename(url)

appyter.ext.uuid module

appyter.ext.uuid.generate_uuid()

appyter.ext.uuid.sanitize_sha1sum(val)

appyter.ext.uuid.sanitize_uuid(val)

Module contents