armonik package

Subpackages

• armonik.client package
  • Submodules
  • armonik.client.events module
  • armonik.client.health_checks module
  • armonik.client.partitions module
  • armonik.client.results module
  • armonik.client.sessions module
  • armonik.client.tasks module
  • armonik.client.versions module
  • Module contents
• armonik.common package
  • Subpackages
    • armonik.common.filter package
      • Submodules
      • armonik.common.filter.filter module
      • Module contents
  • Submodules
  • armonik.common.channel module
    • create_channel()
  • armonik.common.enumwrapper module
    • Direction
    • EventTypes
      • EventTypes.from_string()
    • HealthCheckStatus
    • ResultStatus
      • ResultStatus.name_from_value()
    • ServiceHealthCheckStatus
    • SessionStatus
      • SessionStatus.name_from_value()
    • TaskStatus
  • armonik.common.events module
    • Event
      • Event.from_raw_event()
    • NewResultEvent
      • NewResultEvent.owner_id
      • NewResultEvent.result_id
      • NewResultEvent.status
    • NewTaskEvent
      • NewTaskEvent.data_dependencies
      • NewTaskEvent.expected_output_keys
      • NewTaskEvent.origin_task_id
      • NewTaskEvent.parent_task_ids
      • NewTaskEvent.payload_id
      • NewTaskEvent.retry_of_ids
      • NewTaskEvent.status
      • NewTaskEvent.task_id
    • ResultOwnerUpdateEvent
      • ResultOwnerUpdateEvent.current_owner_id
      • ResultOwnerUpdateEvent.previous_owner_id
      • ResultOwnerUpdateEvent.result_id
    • ResultStatusUpdateEvent
      • ResultStatusUpdateEvent.result_id
      • ResultStatusUpdateEvent.status
    • TaskStatusUpdateEvent
      • TaskStatusUpdateEvent.status
      • TaskStatusUpdateEvent.task_id
  • armonik.common.helpers module
    • batched()
    • datetime_to_timestamp()
    • duration_to_timedelta()
    • get_task_filter()
    • timedelta_to_duration()
    • timestamp_to_datetime()
  • armonik.common.objects module
  • Module contents
• armonik.worker package
  • Submodules
  • armonik.worker.seqlogger module
    • ClefLogger
      • ClefLogger.critical()
      • ClefLogger.debug()
      • ClefLogger.error()
      • ClefLogger.exception()
      • ClefLogger.getLogger()
      • ClefLogger.info()
      • ClefLogger.log()
      • ClefLogger.setLevel()
      • ClefLogger.setup_logging()
      • ClefLogger.warning()
  • armonik.worker.taskhandler module
  • armonik.worker.worker module
  • Module contents

Module contents