Index A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W A ACTIVE (chancy.queue.Queue.State attribute) add() (chancy.plugins.workflow.Sequence method) (chancy.plugins.workflow.Workflow method) (chancy.utils.TaskManager method) add_group() (chancy.plugins.workflow.Workflow method) AndCondition (class in chancy.rule) announce_worker() (chancy.worker.Worker method) Api (class in chancy.plugins.api) api_plugin() (chancy.plugin.Plugin method) (chancy.plugins.cron.Cron method) (chancy.plugins.workflow.WorkflowPlugin method) ApiPlugin (class in chancy.plugins.api.plugin) Async (chancy.app.Chancy.Executor attribute) AsyncExecutor (class in chancy.executors.asyncex) attempt (chancy.job.ErrorT attribute) attempts (chancy.job.QueuedJob attribute) B body (chancy.hub.Event attribute) C calculate_next_run() (chancy.plugins.retry.RetryPlugin static method) cancel() (chancy.executors.asyncex.AsyncExecutor method) (chancy.executors.base.ConcurrentExecutor method) (chancy.executors.base.Executor method) (chancy.executors.process.ProcessExecutor method) cancel_all() (chancy.utils.TaskManager method) cancel_job() (chancy.app.Chancy method) chancy (chancy.worker.Worker attribute) Chancy (class in chancy.app) chancy.app module Chancy.Executor (class in chancy.app) chancy.executors module chancy.executors.asyncex module chancy.executors.base module chancy.executors.process module chancy.executors.sub module chancy.executors.thread module chancy.hub module chancy.job module chancy.migrate module chancy.plugin module chancy.plugins module chancy.plugins.api module chancy.plugins.api.core module chancy.plugins.api.plugin module chancy.plugins.cron module chancy.plugins.cron.api module chancy.plugins.leadership module chancy.plugins.pruner module chancy.plugins.recovery module chancy.plugins.reprioritize module chancy.plugins.retry module chancy.plugins.sentry module chancy.plugins.workflow.api module chancy.queue module chancy.rule module chancy.utils module chancy.worker module chancy_uuid() (in module chancy.utils) chunked() (in module chancy.utils) cleanup() (chancy.plugin.Plugin method) (chancy.plugins.workflow.WorkflowPlugin method) clear() (chancy.hub.Hub method) COMPLETED (chancy.plugins.workflow.Workflow.State attribute) completed_at (chancy.job.QueuedJob attribute) concurrency (chancy.queue.Queue attribute) ConcurrentExecutor (class in chancy.executors.base) Condition (class in chancy.rule) CoreApiPlugin (class in chancy.plugins.api.core) created_at (chancy.plugins.workflow.Workflow attribute) Cron (class in chancy.plugins.cron) CronApiPlugin (class in chancy.plugins.cron.api) D declare() (chancy.app.Chancy method) declare_ex() (chancy.app.Chancy method) delete_queue() (chancy.app.Chancy method) dependencies (chancy.plugins.workflow.WorkflowStep attribute) deserialize() (chancy.job.Limit class method) discover_all_migrations() (chancy.migrate.Migrator method) down() (chancy.migrate.Migration method) dsn (chancy.app.Chancy attribute) E emit() (chancy.hub.Hub method) endpoint (chancy.plugins.api.plugin.RouteT attribute) errors (chancy.job.QueuedJob attribute) ErrorT (class in chancy.job) Event (class in chancy.hub) executor (chancy.queue.Queue attribute) Executor (class in chancy.executors.base) executor_options (chancy.queue.Queue attribute) F FAILED (chancy.job.QueuedJob.State attribute) (chancy.plugins.workflow.Workflow.State attribute) fetch_jobs() (chancy.worker.Worker method) fetch_workflow() (chancy.plugins.workflow.WorkflowPlugin class method) fetch_workflows() (chancy.plugins.workflow.WorkflowPlugin static method) from_func() (chancy.job.Job class method) func (chancy.job.Job attribute) G generate_dot() (chancy.plugins.workflow.WorkflowPlugin static method) get_all_queues() (chancy.app.Chancy method) get_all_workers() (chancy.app.Chancy method) get_configuration() (chancy.plugins.api.core.CoreApiPlugin static method) get_cron() (chancy.plugins.cron.api.CronApiPlugin static method) get_current_version() (chancy.migrate.Migrator method) get_function_and_kwargs() (chancy.executors.base.Executor static method) get_job() (chancy.app.Chancy method) (chancy.plugins.api.core.CoreApiPlugin static method) get_jobs() (chancy.plugins.api.core.CoreApiPlugin static method) get_queue() (chancy.app.Chancy method) get_queues() (chancy.plugins.api.core.CoreApiPlugin static method) get_scope() (chancy.plugin.Plugin class method) (chancy.plugins.api.Api class method) (chancy.plugins.cron.Cron class method) (chancy.plugins.leadership.ImmediateLeadership class method) (chancy.plugins.leadership.Leadership class method) (chancy.plugins.pruner.Pruner class method) (chancy.plugins.recovery.Recovery class method) (chancy.plugins.reprioritize.Reprioritize class method) (chancy.plugins.retry.RetryPlugin class method) (chancy.plugins.workflow.WorkflowPlugin class method) get_workers() (chancy.plugins.api.core.CoreApiPlugin static method) get_workflow() (chancy.plugins.workflow.api.WorkflowApiPlugin static method) get_workflows() (chancy.plugins.workflow.api.WorkflowApiPlugin static method) H heartbeat_poll_interval (chancy.worker.Worker attribute) heartbeat_timeout (chancy.worker.Worker attribute) hub (chancy.worker.Worker attribute) Hub (class in chancy.hub) I id (chancy.job.QueuedJob attribute) (chancy.plugins.workflow.Workflow attribute) identifier (chancy.job.Reference attribute) ImmediateLeadership (class in chancy.plugins.leadership) import_string() (in module chancy.utils) importable_name() (in module chancy.utils) is_complete (chancy.plugins.workflow.Workflow property) is_leader (chancy.worker.Worker attribute) is_migration_required() (chancy.migrate.Migrator method) is_running (chancy.plugins.workflow.Workflow property) is_up_to_date() (chancy.app.Chancy method) IsAJob (class in chancy.job) J job (chancy.job.IsAJob attribute) (chancy.plugins.workflow.WorkflowStep attribute) Job (class in chancy.job) job() (in module chancy.job) job_id (chancy.plugins.workflow.WorkflowStep attribute) job_signal_handler() (chancy.executors.process.ProcessExecutor static method) job_wrapper() (chancy.executors.process.ProcessExecutor class method) (chancy.executors.sub.SubInterpreterExecutor class method) (chancy.executors.thread.ThreadedExecutor method) JobRules (class in chancy.rule) JobRules.Age (class in chancy.rule) JobRules.CreatedAt (class in chancy.rule) JobRules.ID (class in chancy.rule) JobRules.Job (class in chancy.rule) JobRules.Queue (class in chancy.rule) JobRules.ScheduledAt (class in chancy.rule) JobRules.State (class in chancy.rule) json_dumps() (in module chancy.utils) K kwargs (chancy.job.Job attribute) L Leadership (class in chancy.plugins.leadership) Limit (class in chancy.job) Limit.Type (class in chancy.job) limits (chancy.job.Job attribute) log (chancy.app.Chancy attribute) M manager (chancy.worker.Worker attribute) max_attempts (chancy.job.Job attribute) max_connection_pool_size (chancy.app.Chancy attribute) MEMORY (chancy.job.Limit.Type attribute) meta (chancy.job.Job attribute) methods (chancy.plugins.api.plugin.RouteT attribute) migrate() (chancy.app.Chancy method) (chancy.migrate.Migrator method) (chancy.plugin.Plugin method) migrate_key() (chancy.plugin.Plugin method) (chancy.plugins.cron.Cron method) (chancy.plugins.workflow.WorkflowPlugin method) migrate_package() (chancy.plugin.Plugin method) (chancy.plugins.cron.Cron method) (chancy.plugins.workflow.WorkflowPlugin method) Migration (class in chancy.migrate) MigrationError Migrator (class in chancy.migrate) migrator() (chancy.plugin.Plugin method) min_connection_pool_size (chancy.app.Chancy attribute) module chancy.app chancy.executors chancy.executors.asyncex chancy.executors.base chancy.executors.process chancy.executors.sub chancy.executors.thread chancy.hub chancy.job chancy.migrate chancy.plugin chancy.plugins chancy.plugins.api chancy.plugins.api.core chancy.plugins.api.plugin chancy.plugins.cron chancy.plugins.cron.api chancy.plugins.leadership chancy.plugins.pruner chancy.plugins.recovery chancy.plugins.reprioritize chancy.plugins.retry chancy.plugins.sentry chancy.plugins.workflow.api chancy.queue chancy.rule chancy.utils chancy.worker N name (chancy.hub.Event attribute) (chancy.plugins.api.plugin.RouteT attribute) (chancy.plugins.workflow.Workflow attribute) (chancy.queue.Queue attribute) name() (chancy.plugins.api.core.CoreApiPlugin method) (chancy.plugins.api.plugin.ApiPlugin method) (chancy.plugins.cron.api.CronApiPlugin method) (chancy.plugins.workflow.api.WorkflowApiPlugin method) notifications (chancy.app.Chancy attribute) notify() (chancy.app.Chancy method) O on() (chancy.hub.Hub method) on_initialize_worker() (chancy.executors.process.ProcessExecutor class method) (chancy.executors.sub.SubInterpreterExecutor static method) on_job_completed() (chancy.executors.base.Executor method) (chancy.plugin.Plugin method) (chancy.plugins.retry.RetryPlugin method) (chancy.plugins.sentry.SentryPlugin method) on_job_starting() (chancy.executors.base.Executor method) (chancy.plugin.Plugin method) on_signal() (chancy.worker.Worker method) on_worker_started() (chancy.plugin.Plugin method) OrCondition (class in chancy.rule) outgoing (chancy.worker.Worker attribute) P pack() (chancy.job.Job method) (chancy.queue.Queue method) path (chancy.plugins.api.plugin.RouteT attribute) PAUSED (chancy.queue.Queue.State attribute) PENDING (chancy.job.QueuedJob.State attribute) (chancy.plugins.workflow.Workflow.State attribute) Plugin (class in chancy.plugin) plugins (chancy.app.Chancy attribute) PluginScope (class in chancy.plugin) poll_reconnect_timeout (chancy.app.Chancy attribute) polling_interval (chancy.queue.Queue attribute) pool (chancy.app.Chancy property) prefix (chancy.app.Chancy attribute) priority (chancy.job.Job attribute) Process (chancy.app.Chancy.Executor attribute) process_workflow() (chancy.plugins.workflow.WorkflowPlugin method) ProcessExecutor (class in chancy.executors.process) prune() (chancy.plugins.pruner.Pruner method) Pruner (class in chancy.plugins.pruner) push() (chancy.app.Chancy method) (chancy.executors.asyncex.AsyncExecutor method) (chancy.executors.base.Executor method) (chancy.executors.process.ProcessExecutor method) (chancy.executors.sub.SubInterpreterExecutor method) (chancy.executors.thread.ThreadedExecutor method) (chancy.plugins.workflow.Sequence method) (chancy.plugins.workflow.WorkflowPlugin class method) push_many() (chancy.app.Chancy method) push_many_ex() (chancy.app.Chancy method) Q queue (chancy.job.Job attribute) Queue (class in chancy.queue) Queue.State (class in chancy.queue) queue_change_poll_interval (chancy.worker.Worker attribute) queue_update() (chancy.worker.Worker method) QueuedJob (class in chancy.job) QueuedJob.State (class in chancy.job) R rate_limit (chancy.queue.Queue attribute) rate_limit_window (chancy.queue.Queue attribute) recover() (chancy.plugins.recovery.Recovery class method) Recovery (class in chancy.plugins.recovery) Reference (class in chancy.job) register_signal_handlers (chancy.worker.Worker attribute) remove() (chancy.hub.Hub method) Reprioritize (class in chancy.plugins.reprioritize) reprioritize_jobs() (chancy.plugins.reprioritize.Reprioritize method) RETRYING (chancy.job.QueuedJob.State attribute) RetryPlugin (class in chancy.plugins.retry) routes() (chancy.plugins.api.core.CoreApiPlugin method) (chancy.plugins.api.plugin.ApiPlugin method) (chancy.plugins.cron.api.CronApiPlugin method) (chancy.plugins.workflow.api.WorkflowApiPlugin method) RouteT (class in chancy.plugins.api.plugin) Rule (class in chancy.rule) Rules (chancy.plugins.pruner.Pruner attribute) (chancy.plugins.reprioritize.Reprioritize attribute) run() (chancy.plugin.Plugin method) (chancy.plugins.api.Api method) (chancy.plugins.cron.Cron method) (chancy.plugins.leadership.ImmediateLeadership method) (chancy.plugins.leadership.Leadership method) (chancy.plugins.pruner.Pruner method) (chancy.plugins.recovery.Recovery method) (chancy.plugins.reprioritize.Reprioritize method) (chancy.plugins.workflow.WorkflowPlugin method) RUNNING (chancy.job.QueuedJob.State attribute) (chancy.plugins.workflow.Workflow.State attribute) S schedule() (chancy.plugins.cron.Cron class method) scheduled_at (chancy.job.Job attribute) send_outgoing_interval (chancy.worker.Worker attribute) SentryPlugin (class in chancy.plugins.sentry) Sequence (class in chancy.plugins.workflow) serialize() (chancy.job.Limit method) set_current_version() (chancy.migrate.Migrator method) setup_default_logger() (in module chancy.app) shutdown_event (chancy.worker.Worker attribute) shutdown_timeout (chancy.worker.Worker attribute) sleep() (chancy.plugin.Plugin method) (in module chancy.utils) SQLAble (class in chancy.rule) start() (chancy.worker.Worker method) started_at (chancy.job.QueuedJob attribute) state (chancy.job.QueuedJob attribute) (chancy.plugins.workflow.Workflow attribute) (chancy.plugins.workflow.WorkflowStep attribute) (chancy.queue.Queue attribute) step_id (chancy.plugins.workflow.WorkflowStep attribute) steps (chancy.plugins.workflow.Workflow attribute) steps_by_state (chancy.plugins.workflow.Workflow property) stop() (chancy.executors.asyncex.AsyncExecutor method) (chancy.executors.base.Executor method) (chancy.executors.process.ProcessExecutor method) (chancy.executors.sub.SubInterpreterExecutor method) (chancy.executors.thread.ThreadedExecutor method) (chancy.worker.Worker method) SubInterpreter (chancy.app.Chancy.Executor attribute) SubInterpreterExecutor (class in chancy.executors.sub) SUCCEEDED (chancy.job.QueuedJob.State attribute) sync_notify() (chancy.app.Chancy method) sync_pool (chancy.app.Chancy property) sync_push() (chancy.app.Chancy method) sync_push_many() (chancy.app.Chancy method) sync_push_many_ex() (chancy.app.Chancy method) T tags (chancy.queue.Queue attribute) TaskManager (class in chancy.utils) Threaded (chancy.app.Chancy.Executor attribute) ThreadedExecutor (class in chancy.executors.thread) TIME (chancy.job.Limit.Type attribute) timed_block() (in module chancy.utils) to_sql() (chancy.plugins.workflow.WorkflowPlugin.Rules.Age method) (chancy.rule.AndCondition method) (chancy.rule.Condition method) (chancy.rule.JobRules.Age method) (chancy.rule.OrCondition method) (chancy.rule.Rule method) (chancy.rule.SQLAble method) traceback (chancy.job.ErrorT attribute) type_ (chancy.job.Limit attribute) U unique_key (chancy.job.Job attribute) unpack() (chancy.job.Job class method) (chancy.job.QueuedJob class method) (chancy.queue.Queue class method) unschedule() (chancy.plugins.cron.Cron class method) up() (chancy.migrate.Migration method) updated_at (chancy.plugins.workflow.Workflow attribute) upsert_version_table() (chancy.migrate.Migrator method) V value (chancy.job.Limit attribute) W wait_for() (chancy.hub.Hub method) wait_for_job() (chancy.app.Chancy method) wait_for_leader() (chancy.plugin.Plugin static method) wait_for_shutdown() (chancy.utils.TaskManager method) (chancy.worker.Worker method) wait_for_workflow() (chancy.plugins.workflow.WorkflowPlugin class method) wake_up() (chancy.plugin.Plugin method) wakeup_signal (chancy.plugin.Plugin attribute) with_kwargs() (chancy.job.Job method) with_limits() (chancy.job.Job method) with_max_attempts() (chancy.job.Job method) with_meta() (chancy.job.Job method) with_priority() (chancy.job.Job method) with_queue() (chancy.job.Job method) with_scheduled_at() (chancy.job.Job method) with_unique_key() (chancy.job.Job method) WORKER (chancy.plugin.PluginScope attribute) Worker (class in chancy.worker) worker_id (chancy.worker.Worker attribute) worker_tags() (chancy.worker.Worker method) Workflow (class in chancy.plugins.workflow) Workflow.State (class in chancy.plugins.workflow) WorkflowApiPlugin (class in chancy.plugins.workflow.api) WorkflowPlugin (class in chancy.plugins.workflow) WorkflowPlugin.Rules (class in chancy.plugins.workflow) WorkflowPlugin.Rules.Age (class in chancy.plugins.workflow) WorkflowStep (class in chancy.plugins.workflow)