Index

_

__init__() (NotificationService method) (TaskExecutor method) (TaskManager method) (TaskService method)

A

ABORTED (ExitCode attribute)

app_name (Task attribute)

C

commands (Task attribute) condition (TaskCommand attribute) create() (NotificationService method) (TaskService method)

created (Notification attribute) (Task attribute) cron (Task attribute) CURRENT (RestartPolicy attribute)

D

DEFAULT_ROW_LIMIT (NotificationService attribute) (TaskService attribute) DEFAULT_T (Limit attribute) delete() (NotificationService method) (TaskService method)

delete_condition_hook() (NotificationService static method) (TaskService static method) delete_old_tasks() (TaskService method) description (Task attribute) discover_service() (NotificationService method) (TaskService method)

E

enabled (Notification attribute) (Task attribute) error (Notification attribute) (Task attribute) exec_deadline (Task attribute) execute_stage() (TaskManager method) EXECUTED (TaskStatus attribute)

EXECUTION_ERROR (ExitCode attribute) executor_id (Task attribute) exists() (NotificationService method) (TaskService method) exit_code (Notification attribute) (Task attribute) ExitCode (class in kaiju_tasks.types)

F

FAILED (TaskStatus attribute)

FINISHED (TaskStatus attribute) FIRST (RestartPolicy attribute)

G

get() (NotificationService method) (TaskService method) get_condition_hook() (NotificationService static method) (TaskService static method) get_request_context() (NotificationService method) (TaskService method)

get_session() (NotificationService method) (TaskService method) get_user_id() (NotificationService method) (TaskService method) group (Task attribute) group_id (Task attribute)

H

has_permission() (NotificationService method) (TaskService method)

I

id (Notification attribute) (Task attribute) IDLE (TaskStatus attribute) insert_columns (NotificationService attribute) (TaskService attribute)

insert_condition_hook() (NotificationService static method) (TaskService static method) iter() (NotificationService method) (TaskService method)

J

job_id (Notification attribute) (Task attribute)

K

kws (Notification attribute) (Task attribute)

L

Limit (class in kaiju_tasks.types) list() (NotificationService method) (TaskService method)

list_active_executors() (TaskManager method)

M

m_create() (NotificationService method) (TaskService method) m_delete() (NotificationService method) (TaskService method) m_exists() (NotificationService method) (TaskService method) m_get() (NotificationService method) (TaskService method) m_update() (NotificationService method) (TaskService method) max_exec_timeout (Task attribute) MAX_RETRIES (Limit attribute)

max_retries (Task attribute) MAX_ROW_LIMIT (NotificationService attribute) (TaskService attribute) MAX_STAGES (Limit attribute) MAX_T (Limit attribute) max_timeout (Message attribute) (TaskCommand attribute) Message (class in kaiju_tasks.types) message (Notification attribute) meta (Task attribute) method (TaskCommand attribute) MIN_T (Limit attribute)

N

next_run (Task attribute) next_task (Task attribute)

Notification (class in kaiju_tasks.types) NotificationService (class in kaiju_tasks.services) notify (Task attribute)

P

params (TaskCommand attribute) permission_modify (NotificationService property) (TaskService property) permission_view (NotificationService property) (TaskService property)

ping() (TaskManager method) PING_INTERVAL (Limit attribute) prepare_insert_data() (NotificationService static method) (TaskService method) prepare_update_data() (NotificationService static method) (TaskService method)

Q

QUEUED (TaskStatus attribute)

queued_at (Task attribute)

R

reset_task() (TaskService method) restart_policy (Task attribute) RestartPolicy (class in kaiju_tasks.types)

result (Notification attribute) (Task attribute) retries (Task attribute) run_task() (TaskExecutor method)

S

select_columns (NotificationService attribute) (TaskService attribute) service_name (NotificationService attribute) (TaskManager attribute) (TaskService attribute) stage (Task attribute) stages (Task attribute) status (Notification attribute) (Task attribute)

status_change (Task attribute) SUCCESS (ExitCode attribute) SUSPEND_AFTER_PINGS (Limit attribute) suspend_executor() (TaskManager method) SUSPENDED (TaskStatus attribute) system (Task attribute) system_user() (NotificationService method) (TaskService method)

T

Task (class in kaiju_tasks.types) task_id (Notification attribute) TaskCommand (class in kaiju_tasks.types) TaskExecutor (class in kaiju_tasks.services)

TaskManager (class in kaiju_tasks.services) TaskService (class in kaiju_tasks.services) TaskStatus (class in kaiju_tasks.types) Timer (class in kaiju_tasks.types) timer (Timer attribute)

U

update() (NotificationService method) (TaskService method) update_columns (NotificationService attribute) (TaskService attribute)

update_condition_hook() (NotificationService static method) (TaskService static method) user_id (Notification attribute) (Task attribute)

W

wait_deadline (Task attribute) wait_for_message() (TaskManager method) wait_for_timer() (TaskManager method)

WAITING (TaskStatus attribute) write_message() (TaskService method) write_stage() (TaskManager method)