Index

A

AbstractAction (class in karya.entities.abstracts) AbstractPlanType (class in karya.entities.abstracts) action (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.entities.Hook attribute), [1] (karya.entities.Plan attribute), [1]

api_version (karya.clients.KaryaRestClient attribute)

B

base_url (karya.entities.actions.RestApiRequest attribute), [1]

body (karya.entities.actions.RestApiRequest attribute), [1]

C

cancel_plan() (karya.clients.KaryaRestClient method) CANCELLED (karya.entities.enums.PlanStatus attribute) (karya.entities.enums.TaskStatus attribute) ChainedRequest (class in karya.entities.actions) channel (karya.entities.actions.SlackMessageRequest attribute), [1] ClientConfig (class in karya.clients.config) close() (karya.clients.KaryaRestClient method)

COMPLETED (karya.entities.enums.PlanStatus attribute) create_user() (karya.clients.KaryaRestClient method) CREATED (karya.entities.enums.PlanStatus attribute) (karya.entities.enums.TaskStatus attribute) created_at (karya.entities.Plan attribute), [1] (karya.entities.Task attribute), [1] (karya.entities.User attribute), [1] CreateUserRequest (class in karya.clients.requests)

D

DELETE (karya.entities.enums.Method attribute) description (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.entities.Plan attribute), [1]

dev() (karya.clients.config.ClientConfig static method)

E

EmailRequest (class in karya.entities.actions) end_at (karya.entities.plan_types.Recurring attribute), [1] error (karya.entities.ErrorLog attribute), [1] error_logs (karya.clients.responses.GetSummaryResponse attribute), [1]

ErrorLog (class in karya.entities) ErrorLog.AbstractErrorLogType (class in karya.entities) ErrorLog.ExecutorErrorLog (class in karya.entities) ErrorLog.HookErrorLog (class in karya.entities) executed_at (karya.entities.Task attribute), [1]

F

FAILURE (karya.entities.enums.TaskStatus attribute)

from_dict() (karya.entities.actions.RestApiRequest.JsonBody class method)

G

GET (karya.entities.enums.Method attribute) get_base_url() (karya.clients.config.ClientConfig method) get_plan() (karya.clients.KaryaRestClient method)

get_summary() (karya.clients.KaryaRestClient method) get_user() (karya.clients.KaryaRestClient method) GetPlanResponse (class in karya.clients.responses) GetSummaryResponse (class in karya.clients.responses)

H

headers (karya.entities.actions.RestApiRequest attribute), [1] Hook (class in karya.entities) hook (karya.entities.Plan attribute), [1] hooks (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.clients.requests.UpdatePlanRequest attribute), [1]

host (karya.clients.config.ClientConfig attribute), [1] HTTP (karya.entities.enums.Protocol attribute) HTTPS (karya.entities.enums.Protocol attribute)

I

id (karya.entities.Plan attribute), [1] (karya.entities.Task attribute), [1] (karya.entities.User attribute), [1]

J

json_string (karya.entities.actions.RestApiRequest.JsonBody attribute), [1]

K

KafkaProducerRequest (class in karya.entities.actions) karya.clients module karya.clients.config module karya.clients.requests module karya.clients.responses module karya.entities module

karya.entities.abstracts module karya.entities.actions module karya.entities.enums module karya.entities.plan_types module KaryaRestClient (class in karya.clients) key (karya.entities.actions.KafkaProducerRequest attribute), [1]

L

latest_task (karya.clients.responses.GetPlanResponse attribute), [1]

list_plans() (karya.clients.KaryaRestClient method) ListPlanResponse (class in karya.clients.responses)

M

main() (in module samples.make_delayed_api_call_with_failure_hook) (in module samples.make_delayed_chained_karya_call) (in module samples.make_delayed_email_request) (in module samples.make_recurring_api_call) (in module samples.make_recurring_push_to_kafka) (in module samples.make_recurring_slack_request) max_failure_retry (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.clients.requests.UpdatePlanRequest attribute), [1] (karya.entities.Plan attribute), [1] max_retry (karya.entities.Hook attribute), [1] message (karya.entities.actions.EmailRequest attribute), [1] (karya.entities.actions.KafkaProducerRequest attribute), [1] (karya.entities.actions.SlackMessageRequest attribute), [1] Method (class in karya.entities.enums) method (karya.entities.actions.RestApiRequest attribute), [1]

module karya.clients karya.clients.config karya.clients.requests karya.clients.responses karya.entities karya.entities.abstracts karya.entities.actions karya.entities.enums karya.entities.plan_types samples.make_delayed_api_call_with_failure_hook samples.make_delayed_chained_karya_call samples.make_delayed_email_request samples.make_recurring_api_call samples.make_recurring_push_to_kafka samples.make_recurring_slack_request

N

name (karya.clients.requests.CreateUserRequest attribute), [1] (karya.entities.User attribute), [1]

next_execution_at (karya.entities.Task attribute), [1]

O

offset (karya.clients.responses.ListPlanResponse attribute), [1] ON_COMPLETION (karya.entities.enums.Trigger attribute)

ON_FAILURE (karya.entities.enums.Trigger attribute) OneTime (class in karya.entities.plan_types)

P

parent_plan_id (karya.entities.Plan attribute), [1] partition_key (karya.entities.Task attribute), [1] PATCH (karya.entities.enums.Method attribute) period_time (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.clients.requests.UpdatePlanRequest attribute), [1] (karya.entities.Plan attribute), [1] Plan (class in karya.entities) plan (karya.clients.responses.GetPlanResponse attribute), [1] (karya.clients.responses.GetSummaryResponse attribute), [1] plan_id (karya.clients.requests.UpdatePlanRequest attribute), [1] (karya.entities.ErrorLog attribute), [1] (karya.entities.Task attribute), [1]

plan_type (karya.clients.requests.SubmitPlanRequest attribute), [1] plans (karya.clients.responses.ListPlanResponse attribute), [1] PlanStatus (class in karya.entities.enums) port (karya.clients.config.ClientConfig attribute), [1] POST (karya.entities.enums.Method attribute) PROCESSING (karya.entities.enums.TaskStatus attribute) Protocol (class in karya.entities.enums) protocol (karya.clients.config.ClientConfig attribute), [1] (karya.entities.actions.RestApiRequest attribute), [1]

R

recipient (karya.entities.actions.EmailRequest attribute), [1] Recurring (class in karya.entities.plan_types) request (karya.entities.actions.ChainedRequest attribute), [1] RestApiRequest (class in karya.entities.actions)

RestApiRequest.AbstractBody (class in karya.entities.actions) RestApiRequest.EmptyBody (class in karya.entities.actions) RestApiRequest.JsonBody (class in karya.entities.actions) RUNNING (karya.entities.enums.PlanStatus attribute)

S

samples.make_delayed_api_call_with_failure_hook module samples.make_delayed_chained_karya_call module samples.make_delayed_email_request module samples.make_recurring_api_call module samples.make_recurring_push_to_kafka module

samples.make_recurring_slack_request module SlackMessageRequest (class in karya.entities.actions) status (karya.entities.Plan attribute), [1] (karya.entities.Task attribute), [1] subject (karya.entities.actions.EmailRequest attribute), [1] submit_plan() (karya.clients.KaryaRestClient method) SubmitPlanRequest (class in karya.clients.requests) SUCCESS (karya.entities.enums.TaskStatus attribute)

T

Task (class in karya.entities) task_id (karya.entities.ErrorLog.ExecutorErrorLog attribute), [1] tasks (karya.clients.responses.GetSummaryResponse attribute), [1] TaskStatus (class in karya.entities.enums) timeout (karya.entities.actions.RestApiRequest attribute), [1] timestamp (karya.entities.ErrorLog attribute), [1] topic (karya.entities.actions.KafkaProducerRequest attribute), [1] total (karya.clients.responses.ListPlanResponse attribute), [1] Trigger (class in karya.entities.enums) trigger (karya.entities.Hook attribute), [1]

type (karya.entities.actions.ChainedRequest attribute) (karya.entities.actions.EmailRequest attribute) (karya.entities.actions.KafkaProducerRequest attribute) (karya.entities.actions.RestApiRequest attribute) (karya.entities.actions.RestApiRequest.EmptyBody attribute) (karya.entities.actions.RestApiRequest.JsonBody attribute) (karya.entities.actions.SlackMessageRequest attribute) (karya.entities.ErrorLog attribute), [1] (karya.entities.Plan attribute), [1] (karya.entities.plan_types.OneTime attribute) (karya.entities.plan_types.Recurring attribute)

U

update_plan() (karya.clients.KaryaRestClient method) updated_at (karya.entities.Plan attribute), [1] UpdatePlanRequest (class in karya.clients.requests)

User (class in karya.entities) user_id (karya.clients.requests.SubmitPlanRequest attribute), [1] (karya.entities.Plan attribute), [1]