Index

_

__aenter__() (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) __aexit__() (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) __init__() (flowrra.app.Flowrra method) (flowrra.BackendConfig method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) (flowrra.BrokerConfig method) (flowrra.brokers.redis.RedisBroker method) (flowrra.brokers.RedisBroker method) (flowrra.Config method) (flowrra.config.BackendConfig method) (flowrra.config.BrokerConfig method) (flowrra.config.Config method) (flowrra.config.ExecutorConfig method) (flowrra.config.SchedulerConfig method) (flowrra.CPUExecutor method) (flowrra.events.EventBus method) (flowrra.exceptions.ExecutorNotRunningError method) (flowrra.exceptions.TaskNotFoundError method) (flowrra.exceptions.TaskTimeoutError method) (flowrra.ExecutorConfig method) (flowrra.ExecutorNotRunningError method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.executors.cpu_executor.CPUExecutor method) (flowrra.executors.CPUExecutor method) (flowrra.executors.io_executor.IOExecutor method) (flowrra.executors.IOExecutor method) (flowrra.Flowrra method) (flowrra.IOExecutor method) (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.registry.TaskRegistry method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) (flowrra.scheduler.cron.CronExpression method) (flowrra.scheduler.CronExpression method) (flowrra.scheduler.models.ScheduledTask method) (flowrra.scheduler.ScheduledTask method) (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) (flowrra.Task method) (flowrra.task.Task method) (flowrra.task.TaskResult method) (flowrra.TaskNotFoundError method) (flowrra.TaskRegistry method) (flowrra.TaskResult method) (flowrra.TaskTimeoutError method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.base.ui_service.UIService method) (flowrra.ui.base.UIService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.django_websocket.FlowrraConsumer method) (flowrra.ui.ScheduleService method) (flowrra.ui.UIService method)

__len__() (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) __post_init__() (flowrra.BackendConfig method) (flowrra.BrokerConfig method) (flowrra.Config method) (flowrra.config.BackendConfig method) (flowrra.config.BrokerConfig method) (flowrra.config.Config method) (flowrra.config.ExecutorConfig method) (flowrra.config.SchedulerConfig method) (flowrra.ExecutorConfig method) __repr__() (flowrra.scheduler.cron.CronExpression method) (flowrra.scheduler.CronExpression method) __str__() (flowrra.scheduler.cron.CronExpression method) (flowrra.scheduler.CronExpression method)

A

args (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute) (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute)

async_subscribe() (flowrra.events.EventBus method)

B

backend (flowrra.Config attribute) (flowrra.config.Config attribute) BackendConfig (class in flowrra) (class in flowrra.config) BackendError, [1] BaseBroker (class in flowrra.brokers) (class in flowrra.brokers.base) BaseResultBackend (class in flowrra.backends) (class in flowrra.backends.base) BaseSchedulerBackend (class in flowrra.scheduler.backends) (class in flowrra.scheduler.backends.base)

BaseTaskExecutor (class in flowrra.executors) (class in flowrra.executors.base) BaseUIAdapter (class in flowrra.ui) (class in flowrra.ui.base) (class in flowrra.ui.base.adapter) broker (flowrra.Config attribute) (flowrra.config.Config attribute) BrokerConfig (class in flowrra) (class in flowrra.config)

C

check_interval (flowrra.config.SchedulerConfig attribute) clear() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) close() (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) (flowrra.brokers.base.BaseBroker method) (flowrra.brokers.BaseBroker method) (flowrra.brokers.redis.RedisBroker method) (flowrra.brokers.RedisBroker method) (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) Config (class in flowrra) (class in flowrra.config) connect() (flowrra.ui.django_websocket.FlowrraConsumer method) cpu_bound (flowrra.Task attribute) (flowrra.task.Task attribute) cpu_workers (flowrra.config.ExecutorConfig attribute) (flowrra.ExecutorConfig attribute) CPUExecutor (class in flowrra) (class in flowrra.executors) (class in flowrra.executors.cpu_executor)

create() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) create_backend() (flowrra.BackendConfig method) (flowrra.Config method) (flowrra.config.BackendConfig method) (flowrra.config.Config method) (flowrra.config.SchedulerConfig method) create_broker() (flowrra.BrokerConfig method) (flowrra.Config method) (flowrra.config.BrokerConfig method) (flowrra.config.Config method) create_schedule_cron() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method) create_schedule_interval() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) create_scheduler() (flowrra.app.Flowrra method) (flowrra.Flowrra method) create_scheduler_backend() (flowrra.Config method) (flowrra.config.Config method) created_at (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] CRON (flowrra.scheduler.models.ScheduleType attribute) (flowrra.scheduler.ScheduleType attribute) CronExpression (class in flowrra.scheduler) (class in flowrra.scheduler.cron) current_retry (flowrra.Task attribute) (flowrra.task.Task attribute)

D

database_url (flowrra.config.SchedulerConfig attribute) delete() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) delete_schedule() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method)

description (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] disable_schedule() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method) disable_task() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) disconnect() (flowrra.ui.django_websocket.FlowrraConsumer method)

E

emit() (flowrra.events.EventBus method) enable_schedule() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method) enable_task() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method)

enabled (flowrra.config.SchedulerConfig attribute) (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] error (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) EventBus (class in flowrra.events) executor (flowrra.Config attribute) (flowrra.config.Config attribute) ExecutorConfig (class in flowrra) (class in flowrra.config) ExecutorNotRunningError, [1]

F

FAILED (flowrra.task.TaskStatus attribute) (flowrra.TaskStatus attribute) find_by_definition() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) finished_at (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) flowrra module Flowrra (class in flowrra) (class in flowrra.app) flowrra.app module flowrra.backends module flowrra.backends.base module flowrra.backends.factory module flowrra.backends.memory module flowrra.backends.redis module flowrra.brokers module flowrra.brokers.base module flowrra.brokers.factory module flowrra.brokers.redis module flowrra.config module flowrra.constants module flowrra.events module flowrra.exceptions module flowrra.executors module flowrra.executors.base module flowrra.executors.cpu_executor module flowrra.executors.io_executor module flowrra.management module flowrra.management.manager module flowrra.registry module flowrra.scheduler module

flowrra.scheduler.backends module flowrra.scheduler.backends.base module flowrra.scheduler.backends.mysql module flowrra.scheduler.backends.postgresql module flowrra.scheduler.backends.sqlite module flowrra.scheduler.cron module flowrra.scheduler.models module flowrra.scheduler.scheduler module flowrra.task module flowrra.ui module flowrra.ui.base module flowrra.ui.base.adapter module flowrra.ui.base.formatter module flowrra.ui.base.schedule_service module flowrra.ui.base.ui_service module flowrra.ui.django_websocket module flowrra.ui.quart_websocket module FlowrraConsumer (class in flowrra.ui.django_websocket) FlowrraError, [1] FlowrraManager (class in flowrra.management) (class in flowrra.management.manager) format_datetime() (flowrra.ui.base.adapter.BaseUIAdapter static method) (flowrra.ui.base.BaseUIAdapter static method) (flowrra.ui.base.Formatter static method) (flowrra.ui.base.formatter.Formatter static method) (flowrra.ui.BaseUIAdapter static method) (flowrra.ui.Formatter static method) format_duration() (flowrra.ui.base.adapter.BaseUIAdapter static method) (flowrra.ui.base.BaseUIAdapter static method) (flowrra.ui.base.Formatter static method) (flowrra.ui.base.formatter.Formatter static method) (flowrra.ui.BaseUIAdapter static method) (flowrra.ui.Formatter static method) Formatter (class in flowrra.ui) (class in flowrra.ui.base) (class in flowrra.ui.base.formatter) from_dict() (flowrra.scheduler.models.ScheduledTask class method) (flowrra.scheduler.ScheduledTask class method) (flowrra.task.TaskResult class method) (flowrra.TaskResult class method) from_env() (flowrra.Config class method) (flowrra.config.Config class method) from_urls() (flowrra.app.Flowrra class method) (flowrra.Flowrra class method)

G

get() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) (flowrra.registry.TaskRegistry method) (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) (flowrra.TaskRegistry method) get_backend() (in module flowrra.backends) (in module flowrra.backends.factory) get_broker() (in module flowrra.brokers.factory) get_dashboard_data() (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.ui_service.UIService method) (flowrra.ui.base.UIService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.UIService method) get_or_raise() (flowrra.registry.TaskRegistry method) (flowrra.TaskRegistry method) get_result() (flowrra.app.Flowrra method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.Flowrra method) get_routes() (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.BaseUIAdapter method) get_schedule() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method)

get_scheduled_task() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) get_scheduler_backend() (in module flowrra.scheduler.backends) get_scheduler_stats() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) get_schedules_page_data() (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.ui_service.UIService method) (flowrra.ui.base.UIService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.UIService method) get_stats() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.BaseUIAdapter method) get_status_color() (flowrra.ui.base.adapter.BaseUIAdapter static method) (flowrra.ui.base.BaseUIAdapter static method) (flowrra.ui.base.Formatter static method) (flowrra.ui.base.formatter.Formatter static method) (flowrra.ui.BaseUIAdapter static method) (flowrra.ui.Formatter static method) get_task() (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.BaseUIAdapter method) get_task_info() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) get_task_result() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) get_tasks_page_data() (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.ui_service.UIService method) (flowrra.ui.base.UIService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.UIService method)

H

health_check() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.BaseUIAdapter method)

I

id (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute) InMemoryBackend (class in flowrra.backends) (class in flowrra.backends.memory) INTERVAL (flowrra.scheduler.models.ScheduleType attribute) (flowrra.scheduler.ScheduleType attribute) io_workers (flowrra.config.ExecutorConfig attribute) (flowrra.ExecutorConfig attribute) IOExecutor (class in flowrra) (class in flowrra.executors) (class in flowrra.executors.io_executor) is_broker() (flowrra.executors.io_executor.IOExecutor method) (flowrra.executors.IOExecutor method) (flowrra.IOExecutor method)

is_complete (flowrra.task.TaskResult property) (flowrra.TaskResult property) is_registered() (flowrra.registry.TaskRegistry method) (flowrra.TaskRegistry method) is_running (flowrra.app.Flowrra property) (flowrra.executors.base.BaseTaskExecutor property) (flowrra.executors.BaseTaskExecutor property) (flowrra.Flowrra property) (flowrra.scheduler.Scheduler property) (flowrra.scheduler.scheduler.Scheduler property) is_success (flowrra.task.TaskResult property) (flowrra.TaskResult property)

K

kwargs (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute) (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute)

L

last_run_at (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] list_all() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) list_by_status() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) list_completed_tasks() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) list_due() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) list_enabled() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method)

list_failed_tasks() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) list_pending_tasks() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) list_registered_tasks() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) list_running_tasks() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) list_scheduled_tasks() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) list_schedules() (flowrra.management.FlowrraManager method) (flowrra.management.manager.FlowrraManager method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.base.schedule_service.ScheduleService method) (flowrra.ui.base.ScheduleService method) (flowrra.ui.BaseUIAdapter method) (flowrra.ui.ScheduleService method) list_tasks() (flowrra.registry.TaskRegistry method) (flowrra.TaskRegistry method) (flowrra.ui.base.adapter.BaseUIAdapter method) (flowrra.ui.base.BaseUIAdapter method) (flowrra.ui.BaseUIAdapter method)

M

matches() (flowrra.scheduler.cron.CronExpression method) (flowrra.scheduler.CronExpression method) max_connections (flowrra.BackendConfig attribute) (flowrra.BrokerConfig attribute) (flowrra.config.BackendConfig attribute) (flowrra.config.BrokerConfig attribute) max_queue_size (flowrra.config.ExecutorConfig attribute) (flowrra.ExecutorConfig attribute) max_retries (flowrra.config.ExecutorConfig attribute) (flowrra.ExecutorConfig attribute) (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute) module flowrra flowrra.app flowrra.backends flowrra.backends.base flowrra.backends.factory flowrra.backends.memory flowrra.backends.redis flowrra.brokers flowrra.brokers.base flowrra.brokers.factory flowrra.brokers.redis flowrra.config flowrra.constants flowrra.events flowrra.exceptions flowrra.executors flowrra.executors.base flowrra.executors.cpu_executor flowrra.executors.io_executor flowrra.management flowrra.management.manager flowrra.registry flowrra.scheduler flowrra.scheduler.backends flowrra.scheduler.backends.base flowrra.scheduler.backends.mysql flowrra.scheduler.backends.postgresql flowrra.scheduler.backends.sqlite flowrra.scheduler.cron flowrra.scheduler.models flowrra.scheduler.scheduler flowrra.task flowrra.ui flowrra.ui.base flowrra.ui.base.adapter flowrra.ui.base.formatter flowrra.ui.base.schedule_service flowrra.ui.base.ui_service flowrra.ui.django_websocket flowrra.ui.quart_websocket

MySQLSchedulerBackend (class in flowrra.scheduler.backends) (class in flowrra.scheduler.backends.mysql)

N

name (flowrra.Task attribute) (flowrra.task.Task attribute) next_run() (flowrra.scheduler.cron.CronExpression method) (flowrra.scheduler.CronExpression method)

next_run_at (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1]

O

ONE_TIME (flowrra.scheduler.models.ScheduleType attribute) (flowrra.scheduler.ScheduleType attribute)

P

PENDING (flowrra.task.TaskStatus attribute) (flowrra.TaskStatus attribute) pop() (flowrra.brokers.base.BaseBroker method) (flowrra.brokers.BaseBroker method) (flowrra.brokers.redis.RedisBroker method) (flowrra.brokers.RedisBroker method) PostgreSQLSchedulerBackend (class in flowrra.scheduler.backends) (class in flowrra.scheduler.backends.postgresql)

priority (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute) push() (flowrra.brokers.base.BaseBroker method) (flowrra.brokers.BaseBroker method) (flowrra.brokers.redis.RedisBroker method) (flowrra.brokers.RedisBroker method)

Q

queue_key (flowrra.BrokerConfig attribute) (flowrra.config.BrokerConfig attribute)

R

RedisBackend (class in flowrra.backends) (class in flowrra.backends.redis) RedisBroker (class in flowrra.brokers) (class in flowrra.brokers.redis) registry (flowrra.app.Flowrra property) (flowrra.Flowrra property) result (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) retries (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) retry_delay (flowrra.config.ExecutorConfig attribute) (flowrra.ExecutorConfig attribute) (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.Task attribute) (flowrra.task.Task attribute)

retry_on_timeout (flowrra.BackendConfig attribute) (flowrra.BrokerConfig attribute) (flowrra.config.BackendConfig attribute) (flowrra.config.BrokerConfig attribute) RETRYING (flowrra.task.TaskStatus attribute) (flowrra.TaskStatus attribute) RUNNING (flowrra.task.TaskStatus attribute) (flowrra.TaskStatus attribute)

S

schedule (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] schedule_cron() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) schedule_interval() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) schedule_once() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) schedule_type (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] ScheduledTask (class in flowrra.scheduler) (class in flowrra.scheduler.models) Scheduler (class in flowrra.scheduler) (class in flowrra.scheduler.scheduler) scheduler (flowrra.app.Flowrra property) (flowrra.Config attribute) (flowrra.config.Config attribute) (flowrra.Flowrra property) SchedulerConfig (class in flowrra.config) ScheduleService (class in flowrra.ui) (class in flowrra.ui.base) (class in flowrra.ui.base.schedule_service) ScheduleType (class in flowrra.scheduler) (class in flowrra.scheduler.models) set_submit_callback() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) setup_websocket() (in module flowrra.ui.quart_websocket) size() (flowrra.brokers.base.BaseBroker method) (flowrra.brokers.BaseBroker method) (flowrra.brokers.redis.RedisBroker method) (flowrra.brokers.RedisBroker method) socket_timeout (flowrra.BackendConfig attribute) (flowrra.BrokerConfig attribute) (flowrra.config.BackendConfig attribute) (flowrra.config.BrokerConfig attribute) SQLiteSchedulerBackend (class in flowrra.scheduler.backends) (class in flowrra.scheduler.backends.sqlite) start() (flowrra.app.Flowrra method) (flowrra.CPUExecutor method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.executors.cpu_executor.CPUExecutor method) (flowrra.executors.CPUExecutor method) (flowrra.executors.io_executor.IOExecutor method) (flowrra.executors.IOExecutor method) (flowrra.Flowrra method) (flowrra.IOExecutor method) (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method)

started_at (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) static_dir (flowrra.ui.base.adapter.BaseUIAdapter property) (flowrra.ui.base.BaseUIAdapter property) (flowrra.ui.BaseUIAdapter property) status (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) stop() (flowrra.app.Flowrra method) (flowrra.CPUExecutor method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.executors.cpu_executor.CPUExecutor method) (flowrra.executors.CPUExecutor method) (flowrra.executors.io_executor.IOExecutor method) (flowrra.executors.IOExecutor method) (flowrra.Flowrra method) (flowrra.IOExecutor method) (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) store() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method) submit() (flowrra.app.Flowrra method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.Flowrra method) submitted_at (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) subscribe() (flowrra.events.EventBus method) SUCCESS (flowrra.task.TaskStatus attribute) (flowrra.TaskStatus attribute)

T

Task (class in flowrra) (class in flowrra.task) task() (flowrra.app.Flowrra method) (flowrra.CPUExecutor method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.executors.cpu_executor.CPUExecutor method) (flowrra.executors.CPUExecutor method) (flowrra.executors.io_executor.IOExecutor method) (flowrra.executors.IOExecutor method) (flowrra.Flowrra method) (flowrra.IOExecutor method) (flowrra.registry.TaskRegistry method) (flowrra.TaskRegistry method) task_id (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute) task_name (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] (flowrra.task.TaskResult attribute) (flowrra.TaskResult attribute)

TaskNotFoundError, [1] TaskRegistry (class in flowrra) (class in flowrra.registry) TaskResult (class in flowrra) (class in flowrra.task) TaskStatus (class in flowrra) (class in flowrra.task) TaskTimeoutError, [1] templates_dir (flowrra.ui.base.adapter.BaseUIAdapter property) (flowrra.ui.base.BaseUIAdapter property) (flowrra.ui.BaseUIAdapter property) to_dict (flowrra.task.TaskResult property) (flowrra.TaskResult property) to_dict() (flowrra.scheduler.models.ScheduledTask method) (flowrra.scheduler.ScheduledTask method) ttl (flowrra.BackendConfig attribute) (flowrra.config.BackendConfig attribute)

U

UIService (class in flowrra.ui) (class in flowrra.ui.base) (class in flowrra.ui.base.ui_service) unregister() (flowrra.registry.TaskRegistry method) (flowrra.TaskRegistry method) unschedule() (flowrra.scheduler.Scheduler method) (flowrra.scheduler.scheduler.Scheduler method) unsubscribe() (flowrra.events.EventBus method) update() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method)

update_run_times() (flowrra.scheduler.backends.base.BaseSchedulerBackend method) (flowrra.scheduler.backends.BaseSchedulerBackend method) (flowrra.scheduler.backends.mysql.MySQLSchedulerBackend method) (flowrra.scheduler.backends.MySQLSchedulerBackend method) (flowrra.scheduler.backends.postgresql.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.PostgreSQLSchedulerBackend method) (flowrra.scheduler.backends.sqlite.SQLiteSchedulerBackend method) (flowrra.scheduler.backends.SQLiteSchedulerBackend method) updated_at (flowrra.scheduler.models.ScheduledTask attribute), [1] (flowrra.scheduler.ScheduledTask attribute), [1] url (flowrra.BackendConfig attribute) (flowrra.BrokerConfig attribute) (flowrra.config.BackendConfig attribute) (flowrra.config.BrokerConfig attribute)

W

wait_for() (flowrra.backends.base.BaseResultBackend method) (flowrra.backends.BaseResultBackend method) (flowrra.backends.InMemoryBackend method) (flowrra.backends.memory.InMemoryBackend method) (flowrra.backends.redis.RedisBackend method) (flowrra.backends.RedisBackend method)

wait_for_result() (flowrra.app.Flowrra method) (flowrra.executors.base.BaseTaskExecutor method) (flowrra.executors.BaseTaskExecutor method) (flowrra.Flowrra method) websocket_endpoint() (in module flowrra.ui.quart_websocket)