1. radical

• 1.1. Subpackages
  • 1.1.1. radical.utils.atfork package
    • 1.1.1.1. Submodules
    • 1.1.1.2. radical.utils.atfork.atfork module
      • atfork()
      • child_after_fork_release()
      • monkeypatch_os_fork_functions()
      • os_fork_wrapper()
      • os_forkpty_wrapper()
      • parent_after_fork_release()
      • prepare_to_fork_acquire()
    • 1.1.1.3. radical.utils.atfork.stdlib_fixer module
      • Error
      • fix_logging_module()
    • 1.1.1.4. Module contents
  • 1.1.2. radical.utils.contrib package
    • 1.1.2.1. Submodules
    • 1.1.2.2. radical.utils.contrib.urlparse25 module
      • urldefrag()
      • urljoin()
      • urlparse()
      • urlsplit()
      • urlunparse()
      • urlunsplit()
    • 1.1.2.3. Module contents
  • 1.1.3. utils.plugins package
    • 1.1.3.1. Subpackages
    • 1.1.3.2. Module contents
  • 1.1.4. utils.queue_network package
    • 1.1.4.1. Submodules
    • 1.1.4.2. radical.utils.queue_network.network module
      • Network
    • 1.1.4.3. radical.utils.queue_network.node module
      • Node
    • 1.1.4.4. radical.utils.queue_network.queue module
      • Queue
    • 1.1.4.5. Module contents
  • 1.1.5. utils.scheduler package
    • 1.1.5.1. Submodules
    • 1.1.5.2. radical.utils.scheduler.scheduler_base module
      • SchedulerBase
    • 1.1.5.3. radical.utils.scheduler.scheduler_bitarray module
      • BitarrayScheduler
    • 1.1.5.4. Module contents
  • 1.1.6. utils.zmq package
    • 1.1.6.1. Submodules
    • 1.1.6.2. radical.utils.zmq.bridge module
      • Bridge
    • 1.1.6.3. radical.utils.zmq.client module
      • Client
    • 1.1.6.4. radical.utils.zmq.pubsub module
      • PubSub
      • Publisher
      • Subscriber
    • 1.1.6.5. radical.utils.zmq.queue module
      • Getter
      • Putter
      • Queue
    • 1.1.6.6. radical.utils.zmq.registry module
      • Registry
      • RegistryClient
    • 1.1.6.7. radical.utils.zmq.server module
      • Server
    • 1.1.6.8. radical.utils.zmq.utils module
      • get_channel_url()
      • get_uids()
      • log_bulk()
      • no_intr()
      • prof_bulk()
      • sock_connect()
    • 1.1.6.9. Module contents
• 1.2. Submodules
• 1.3. radical.utils.algorithms module
  • collapse_ranges()
  • in_range()
  • lazy_bisect()
  • partition()
  • range_concurrency()
  • remove_common_prefix()
• 1.4. radical.utils.config module
  • 1.4.1. Config Names and Locations
  • 1.4.2. Queries
  • 1.4.3. Environment
  • 1.4.4. Validation
  • 1.4.5. Implementation
  • Config
    • Config.module
    • Config.category
    • Config.name
    • Config.path
    • Config.cfg
    • Config.from_dict
    • Config.expand
    • Config.env
    • Config.write()
  • DefaultConfig
  • DefaultConfigMeta
• 1.5. radical.utils.constants module
• 1.6. radical.utils.daemon module
  • Daemon
    • Daemon.restart()
    • Daemon.run()
    • Daemon.start()
    • Daemon.stop()
  • daemonize()
• 1.7. radical.utils.debug module
  • DebugHelper
    • DebugHelper.fs_block()
    • DebugHelper.register_lock()
    • DebugHelper.register_rlock()
    • DebugHelper.unregister_lock()
    • DebugHelper.unregister_rlock()
  • Lock
    • Lock.acquire()
    • Lock.release()
  • RLock
    • RLock.acquire()
    • RLock.release()
  • add_snippet_path()
  • attach_pudb()
  • get_caller_name()
  • get_exception_trace()
  • get_snippet()
  • get_stacktrace()
  • get_stacktraces()
  • get_trace()
  • print_exception_trace()
  • print_stacktrace()
  • print_stacktraces()
  • raise_on()
• 1.8. radical.utils.dict_mixin module
  • DictMixin
    • DictMixin.clear()
    • DictMixin.get()
    • DictMixin.has_key()
    • DictMixin.items()
    • DictMixin.iterkeys()
    • DictMixin.itervalues()
    • DictMixin.keys()
    • DictMixin.popitem()
    • DictMixin.setdefault()
    • DictMixin.update()
  • dict_diff()
  • dict_merge()
  • dict_stringexpand()
  • iter_diff()
• 1.9. radical.utils.env module
  • EnvProcess
    • EnvProcess.get()
    • EnvProcess.put()
  • env_diff()
  • env_dump()
  • env_eval()
  • env_prep()
  • env_read()
  • env_read_lines()
  • env_write()
• 1.10. radical.utils.flux module
  • FluxHelper
    • FluxHelper.attach_jobs()
    • FluxHelper.cancel_jobs()
    • FluxHelper.connect_flux()
    • FluxHelper.env
    • FluxHelper.get_executor()
    • FluxHelper.get_handle()
    • FluxHelper.register_callback()
    • FluxHelper.reset()
    • FluxHelper.start_flux()
    • FluxHelper.submit_jobs()
    • FluxHelper.uid
    • FluxHelper.unregister_callback()
    • FluxHelper.uri
• 1.11. radical.utils.futures module
  • Future
    • Future.Run()
    • Future.cancel()
    • Future.exception
    • Future.result
    • Future.run()
    • Future.state
    • Future.traceback
    • Future.wait()
• 1.12. radical.utils.get_version module
  • get_version()
• 1.13. radical.utils.heartbeat module
  • Heartbeat
    • Heartbeat.beat()
    • Heartbeat.dump()
    • Heartbeat.start()
    • Heartbeat.stop()
    • Heartbeat.uid
    • Heartbeat.wait_startup()
• 1.14. radical.utils.host module
  • compress_hostlist()
  • create_hostfile()
  • get_hostip()
  • get_hostlist()
  • get_hostlist_by_range()
  • get_hostname()
  • is_localhost()
• 1.15. radical.utils.ids module
  • generate_id()
  • reset_id_counters()
• 1.16. radical.utils.json_io module
  • metric_expand()
  • parse_json()
  • parse_json_str()
  • read_json()
  • read_json_str()
  • write_json()
• 1.17. radical.utils.lease_manager module
  • LeaseManager
    • LeaseManager.is_locked()
    • LeaseManager.lease()
    • LeaseManager.lock()
    • LeaseManager.locked()
    • LeaseManager.release()
    • LeaseManager.unlock()
• 1.18. radical.utils.lockable module
  • Lockable()
• 1.19. radical.utils.lockfile module
  • Lockfile
    • Lockfile.acquire()
    • Lockfile.get_owner()
    • Lockfile.locked()
    • Lockfile.lseek()
    • Lockfile.read()
    • Lockfile.release()
    • Lockfile.remove()
    • Lockfile.seek()
    • Lockfile.write()
• 1.20. radical.utils.logger module
  • ColorStreamHandler
    • ColorStreamHandler.emit()
  • FSHandler
  • Logger
    • Logger.close()
    • Logger.level
    • Logger.name
    • Logger.ns
    • Logger.path
    • Logger.targets
• 1.21. radical.utils.misc module
  • all_pairs()
  • as_bytes()
  • as_list()
  • as_string()
  • as_tuple()
  • cluster_list()
  • dockerized()
  • expand_env()
  • get_base()
  • get_env_ns()
  • get_radical_base()
  • get_size()
  • is_bytes()
  • is_list()
  • is_seq()
  • is_string()
  • is_tuple()
  • mktar()
  • mongodb_connect()
  • name2env()
  • noop()
  • parse_file_staging_directives()
  • rec_makedir()
  • round_to_base()
  • round_upper_bound()
  • ru_open()
  • script_2_func()
  • split_dburl()
  • time_diff()
  • time_stamp()
  • to_type()
  • watch_condition()
  • window()
• 1.22. radical.utils.modules module
  • find_module()
  • get_type()
  • import_file()
  • import_module()
  • load_class()
• 1.23. radical.utils.object_cache module
  • ObjectCache
    • ObjectCache.get_obj()
    • ObjectCache.is_locked()
    • ObjectCache.lock()
    • ObjectCache.locked()
    • ObjectCache.rem_obj()
    • ObjectCache.unlock()
• 1.24. radical.utils.plugin_manager module
  • PluginBase
    • PluginBase.plugin_class
    • PluginBase.plugin_description
    • PluginBase.plugin_name
    • PluginBase.plugin_type
    • PluginBase.plugin_version
  • PluginManager
    • PluginManager.describe()
    • PluginManager.dump()
    • PluginManager.dump_str()
    • PluginManager.list()
    • PluginManager.list_types()
    • PluginManager.load()
    • PluginManager.load_plugins()
    • PluginManager.register()
    • PluginManager.retrieve()
    • PluginManager.seen()
• 1.25. radical.utils.poll module
  • Poller
    • Poller.close()
    • Poller.modify()
    • Poller.poll()
    • Poller.register()
    • Poller.unregister()
  • poll()
• 1.26. radical.utils.profile module
  • Profiler
    • Profiler.close()
    • Profiler.disable()
    • Profiler.enable()
    • Profiler.enabled
    • Profiler.fields
    • Profiler.flush()
    • Profiler.path
    • Profiler.prof()
    • Profiler.timestamp()
  • clean_profile()
  • combine_profiles()
  • event_to_label()
  • read_profiles()
  • timestamp()
• 1.27. radical.utils.registry module
• 1.28. radical.utils.reporter module
  • Reporter
    • Reporter.COLORS
    • Reporter.DOTTED
    • Reporter.DOUBLE
    • Reporter.EMPTY
    • Reporter.ERROR
    • Reporter.HASHED
    • Reporter.HEADER
    • Reporter.IDLE
    • Reporter.INFO
    • Reporter.MODS
    • Reporter.OK
    • Reporter.PROGRESS
    • Reporter.SINGLE
    • Reporter.TITLE
    • Reporter.WARN
    • Reporter.error()
    • Reporter.exit()
    • Reporter.header()
    • Reporter.idle()
    • Reporter.info()
    • Reporter.ok()
    • Reporter.plain()
    • Reporter.progress()
    • Reporter.progress_done()
    • Reporter.progress_tgt()
    • Reporter.set_style()
    • Reporter.title()
    • Reporter.warn()
• 1.29. radical.utils.ru_regex module
  • ReString
    • ReString.get()
  • ReSult
    • ReSult.get()
    • ReSult.start()
• 1.30. radical.utils.shell module
  • sh_callout()
  • sh_callout_async()
  • sh_callout_bg()
  • sh_quote()
• 1.31. radical.utils.signatures module
  • anything()
  • by_regex()
  • dict_of()
  • list_of()
  • nothing
  • one_of()
  • optional()
  • returns()
  • set_of()
  • takes()
  • tuple_of()
  • with_attr()
• 1.32. radical.utils.singleton module
  • Singleton
• 1.33. radical.utils.stack module
  • stack()
• 1.34. radical.utils.testing module
  • TestConfig
    • TestConfig.add_config()
  • add_test_config()
  • get_test_config()
  • set_test_config()
  • sys_exit()
• 1.35. radical.utils.threads module
  • SignalRaised
  • ThreadExit
  • cancel_main_thread()
  • get_signal_by_name()
  • get_thread_id()
  • get_thread_name()
  • gettid()
  • is_main_thread()
  • is_this_thread()
  • main_thread()
  • raise_in_thread()
  • set_cancellation_handler()
  • this_thread()
  • unset_cancellation_handler()
• 1.36. radical.utils.timing module
  • Time
    • Time.advance()
    • Time.sleep()
    • Time.stop()
    • Time.time()
  • dt_epoch()
  • epoch()
  • timed_method()
• 1.37. radical.utils.tracer module
  • trace()
  • untrace()
• 1.38. radical.utils.typeddict module
  • TDError
  • TDErrorMixin
  • TDKeyError
  • TDTypeError
  • TDValueError
  • TypedDict
    • TypedDict.as_dict()
    • TypedDict.clear()
    • TypedDict.get()
    • TypedDict.items()
    • TypedDict.keys()
    • TypedDict.pop()
    • TypedDict.popitem()
    • TypedDict.setdefault()
    • TypedDict.update()
    • TypedDict.values()
    • TypedDict.verify()
  • TypedDictMeta
  • as_dict()
• 1.39. radical.utils.url module
  • Url
    • Url.fragment
    • Url.get_fragment()
    • Url.get_host()
    • Url.get_password()
    • Url.get_path()
    • Url.get_port()
    • Url.get_query()
    • Url.get_scheme()
    • Url.get_username()
    • Url.host
    • Url.normpath()
    • Url.password
    • Url.path
    • Url.port
    • Url.query
    • Url.schema
    • Url.scheme
    • Url.set_fragment()
    • Url.set_host()
    • Url.set_password()
    • Url.set_path()
    • Url.set_port()
    • Url.set_query()
    • Url.set_scheme()
    • Url.set_username()
    • Url.username
• 1.40. radical.utils.which module
  • which()
• 1.41. Module contents