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.metrics.Metrics 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) AuthBackend (class in chancy.plugins.api) authenticate() (chancy.plugins.api.SimpleAuthBackend method) 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) (chancy.utils.TaskManager 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.errors 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.metrics 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.metrics.Metrics 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.executors.base.Executor property) (chancy.queue.Queue attribute) ConcurrentExecutor (class in chancy.executors.base) Condition (class in chancy.rule) contains() (chancy.rule.Rule method) CoreApiPlugin (class in chancy.plugins.api.core) created_at (chancy.job.QueuedJob attribute) (chancy.plugins.workflow.Workflow attribute) Cron (class in chancy.plugins.cron) CronApiPlugin (class in chancy.plugins.cron.api) D DatabaseConnection (class in chancy.utils) 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) ENGINE (chancy.utils.DatabaseConnection 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) executors (chancy.worker.Worker property) 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_workflow_ex() (chancy.plugins.workflow.WorkflowPlugin class method) fetch_workflows() (chancy.plugins.workflow.WorkflowPlugin class method) fetch_workflows_ex() (chancy.plugins.workflow.WorkflowPlugin static method) free_slots (chancy.executors.base.Executor property) 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_database_dsn() (in module chancy.utils) get_default_concurrency() (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) get_dependencies() (chancy.plugin.Plugin static method) (chancy.plugins.pruner.Pruner static method) (chancy.plugins.recovery.Recovery static method) (chancy.plugins.reprioritize.Reprioritize static method) (chancy.plugins.workflow.WorkflowPlugin static method) get_function_and_kwargs() (chancy.executors.base.Executor static method) get_identifier() (chancy.plugin.Plugin static method) (chancy.plugins.api.Api static method) (chancy.plugins.cron.Cron static method) (chancy.plugins.leadership.ImmediateLeadership static method) (chancy.plugins.leadership.Leadership static method) (chancy.plugins.metrics.Metrics static method) (chancy.plugins.pruner.Pruner static method) (chancy.plugins.recovery.Recovery static method) (chancy.plugins.reprioritize.Reprioritize static method) (chancy.plugins.retry.RetryPlugin static method) (chancy.plugins.sentry.SentryPlugin static method) (chancy.plugins.workflow.WorkflowPlugin 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_metrics() (chancy.plugins.metrics.Metrics method) get_queue() (chancy.app.Chancy method) get_queues() (chancy.plugins.api.core.CoreApiPlugin static method) get_schedules() (chancy.plugins.cron.Cron class method) get_scope() (chancy.plugin.Plugin class method) get_tables() (chancy.plugin.Plugin method) (chancy.plugins.cron.Cron method) (chancy.plugins.leadership.Leadership method) (chancy.plugins.metrics.Metrics method) (chancy.plugins.workflow.WorkflowPlugin 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) HOST (chancy.utils.DatabaseConnection 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) increment_counter() (chancy.plugins.metrics.Metrics method) 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) is_websocket (chancy.plugins.api.plugin.RouteT attribute) 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) login() (chancy.plugins.api.AuthBackend method) (chancy.plugins.api.core.CoreApiPlugin method) (chancy.plugins.api.SimpleAuthBackend method) logout() (chancy.plugins.api.AuthBackend method) (chancy.plugins.api.SimpleAuthBackend method) M manager (chancy.worker.Worker attribute) matches_prefix() (chancy.plugins.metrics.Metrics static method) 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) Metrics (class in chancy.plugins.metrics) 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.metrics.Metrics method) (chancy.plugins.workflow.WorkflowPlugin method) migrate_package() (chancy.plugin.Plugin method) (chancy.plugins.cron.Cron method) (chancy.plugins.metrics.Metrics method) (chancy.plugins.workflow.WorkflowPlugin method) Migration (class in chancy.migrate) MigrationError MigrationsNeededError Migrator (class in chancy.migrate) migrator() (chancy.plugin.Plugin method) min_connection_pool_size (chancy.app.Chancy attribute) module chancy.app chancy.errors 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.metrics 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.utils.DatabaseConnection 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_any() (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_job_updated() (chancy.plugin.Plugin method) (chancy.plugins.metrics.Metrics method) (chancy.plugins.workflow.WorkflowPlugin method) on_signal() (chancy.worker.Worker method) on_worker_started() (chancy.plugin.Plugin method) OPTIONS (chancy.utils.DatabaseConnection attribute) OrCondition (class in chancy.rule) outgoing (chancy.worker.Worker attribute) P pack() (chancy.job.Job method) (chancy.queue.Queue method) PASSWORD (chancy.utils.DatabaseConnection attribute) path (chancy.plugins.api.plugin.RouteT attribute) pause_queue() (chancy.app.Chancy method) 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) PORT (chancy.utils.DatabaseConnection attribute) prefix (chancy.app.Chancy attribute) priority (chancy.job.Job attribute) Process (chancy.app.Chancy.Executor attribute) process_workflow() (chancy.plugins.workflow.WorkflowPlugin static 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_ex() (chancy.app.Chancy method) (chancy.plugins.workflow.WorkflowPlugin static 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) queue_wake_events (chancy.worker.Worker attribute) 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) record_gauge() (chancy.plugins.metrics.Metrics method) record_histogram_value() (chancy.plugins.metrics.Metrics method) 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) remove_on_any() (chancy.hub.Hub method) Reprioritize (class in chancy.plugins.reprioritize) reprioritize_jobs() (chancy.plugins.reprioritize.Reprioritize method) resume_at (chancy.queue.Queue attribute) resume_queue() (chancy.app.Chancy 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.metrics.Metrics 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) SimpleAuthBackend (class in chancy.plugins.api) 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_declare() (chancy.app.Chancy method) sync_declare_ex() (chancy.app.Chancy method) sync_get_job() (chancy.app.Chancy method) 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) USER (chancy.utils.DatabaseConnection attribute) 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)