flowrra

• flowrra package
  • Subpackages
    • flowrra.backends package
      • Submodules
      • flowrra.backends.base module
      • flowrra.backends.factory module
      • flowrra.backends.memory module
      • flowrra.backends.redis module
      • Module contents
    • flowrra.brokers package
      • Submodules
      • flowrra.brokers.base module
      • flowrra.brokers.factory module
      • flowrra.brokers.redis module
      • Module contents
    • flowrra.executors package
      • Submodules
      • flowrra.executors.base module
      • flowrra.executors.cpu_executor module
      • flowrra.executors.io_executor module
      • Module contents
    • flowrra.management package
      • Submodules
      • flowrra.management.manager module
      • Module contents
    • flowrra.scheduler package
      • Subpackages
      • Submodules
      • flowrra.scheduler.cron module
      • flowrra.scheduler.models module
      • flowrra.scheduler.scheduler module
      • Module contents
    • flowrra.ui package
      • Subpackages
      • Submodules
      • flowrra.ui.django module
      • flowrra.ui.django_websocket module
      • flowrra.ui.fastapi module
      • flowrra.ui.flask module
      • flowrra.ui.quart_websocket module
      • Module contents
  • Submodules
  • flowrra.app module
    • Flowrra
      • Flowrra.__init__()
      • Flowrra.from_urls()
      • Flowrra.task()
      • Flowrra.submit()
      • Flowrra.wait_for_result()
      • Flowrra.get_result()
      • Flowrra.start()
      • Flowrra.create_scheduler()
      • Flowrra.stop()
      • Flowrra.is_running
      • Flowrra.registry
      • Flowrra.scheduler
  • flowrra.config module
    • BrokerConfig
      • BrokerConfig.url
      • BrokerConfig.max_connections
      • BrokerConfig.socket_timeout
      • BrokerConfig.retry_on_timeout
      • BrokerConfig.queue_key
      • BrokerConfig.__post_init__()
      • BrokerConfig.create_broker()
      • BrokerConfig.__init__()
    • BackendConfig
      • BackendConfig.url
      • BackendConfig.ttl
      • BackendConfig.max_connections
      • BackendConfig.socket_timeout
      • BackendConfig.retry_on_timeout
      • BackendConfig.__post_init__()
      • BackendConfig.create_backend()
      • BackendConfig.__init__()
    • ExecutorConfig
      • ExecutorConfig.io_workers
      • ExecutorConfig.cpu_workers
      • ExecutorConfig.max_queue_size
      • ExecutorConfig.max_retries
      • ExecutorConfig.retry_delay
      • ExecutorConfig.__post_init__()
      • ExecutorConfig.__init__()
    • SchedulerConfig
      • SchedulerConfig.database_url
      • SchedulerConfig.check_interval
      • SchedulerConfig.enabled
      • SchedulerConfig.__post_init__()
      • SchedulerConfig.create_backend()
      • SchedulerConfig.__init__()
    • Config
      • Config.broker
      • Config.backend
      • Config.executor
      • Config.scheduler
      • Config.__post_init__()
      • Config.create_broker()
      • Config.create_backend()
      • Config.create_scheduler_backend()
      • Config.from_env()
      • Config.__init__()
  • flowrra.constants module
  • flowrra.events module
    • EventBus
      • EventBus.__init__()
      • EventBus.subscribe()
      • EventBus.async_subscribe()
      • EventBus.unsubscribe()
      • EventBus.emit()
  • flowrra.exceptions module
    • FlowrraError
    • TaskNotFoundError
      • TaskNotFoundError.__init__()
    • TaskTimeoutError
      • TaskTimeoutError.__init__()
    • ExecutorNotRunningError
      • ExecutorNotRunningError.__init__()
    • BackendError
  • flowrra.registry module
    • TaskRegistry
      • TaskRegistry.__init__()
      • TaskRegistry.task()
      • TaskRegistry.get()
      • TaskRegistry.get_or_raise()
      • TaskRegistry.list_tasks()
      • TaskRegistry.is_registered()
      • TaskRegistry.unregister()
  • flowrra.task module
    • TaskStatus
      • TaskStatus.PENDING
      • TaskStatus.RUNNING
      • TaskStatus.SUCCESS
      • TaskStatus.FAILED
      • TaskStatus.RETRYING
    • TaskResult
      • TaskResult.task_id
      • TaskResult.status
      • TaskResult.task_name
      • TaskResult.result
      • TaskResult.error
      • TaskResult.submitted_at
      • TaskResult.started_at
      • TaskResult.finished_at
      • TaskResult.retries
      • TaskResult.args
      • TaskResult.kwargs
      • TaskResult.is_complete
      • TaskResult.is_success
      • TaskResult.to_dict
      • TaskResult.from_dict()
      • TaskResult.__init__()
    • Task
      • Task.id
      • Task.name
      • Task.args
      • Task.kwargs
      • Task.max_retries
      • Task.retry_delay
      • Task.current_retry
      • Task.priority
      • Task.cpu_bound
      • Task.__init__()
  • Module contents
    • Flowrra
      • Flowrra.__init__()
      • Flowrra.from_urls()
      • Flowrra.task()
      • Flowrra.submit()
      • Flowrra.wait_for_result()
      • Flowrra.get_result()
      • Flowrra.start()
      • Flowrra.create_scheduler()
      • Flowrra.stop()
      • Flowrra.is_running
      • Flowrra.registry
      • Flowrra.scheduler
    • IOExecutor
      • IOExecutor.__init__()
      • IOExecutor.is_broker()
      • IOExecutor.task()
      • IOExecutor.start()
      • IOExecutor.stop()
    • CPUExecutor
      • CPUExecutor.__init__()
      • CPUExecutor.task()
      • CPUExecutor.start()
      • CPUExecutor.stop()
    • TaskRegistry
      • TaskRegistry.__init__()
      • TaskRegistry.task()
      • TaskRegistry.get()
      • TaskRegistry.get_or_raise()
      • TaskRegistry.list_tasks()
      • TaskRegistry.is_registered()
      • TaskRegistry.unregister()
    • Config
      • Config.broker
      • Config.backend
      • Config.executor
      • Config.scheduler
      • Config.__post_init__()
      • Config.create_broker()
      • Config.create_backend()
      • Config.create_scheduler_backend()
      • Config.from_env()
      • Config.__init__()
    • BrokerConfig
      • BrokerConfig.url
      • BrokerConfig.max_connections
      • BrokerConfig.socket_timeout
      • BrokerConfig.retry_on_timeout
      • BrokerConfig.queue_key
      • BrokerConfig.__post_init__()
      • BrokerConfig.create_broker()
      • BrokerConfig.__init__()
    • BackendConfig
      • BackendConfig.url
      • BackendConfig.ttl
      • BackendConfig.max_connections
      • BackendConfig.socket_timeout
      • BackendConfig.retry_on_timeout
      • BackendConfig.__post_init__()
      • BackendConfig.create_backend()
      • BackendConfig.__init__()
    • ExecutorConfig
      • ExecutorConfig.io_workers
      • ExecutorConfig.cpu_workers
      • ExecutorConfig.max_queue_size
      • ExecutorConfig.max_retries
      • ExecutorConfig.retry_delay
      • ExecutorConfig.__post_init__()
      • ExecutorConfig.__init__()
    • Task
      • Task.id
      • Task.name
      • Task.args
      • Task.kwargs
      • Task.max_retries
      • Task.retry_delay
      • Task.current_retry
      • Task.priority
      • Task.cpu_bound
      • Task.__init__()
    • TaskResult
      • TaskResult.task_id
      • TaskResult.status
      • TaskResult.task_name
      • TaskResult.result
      • TaskResult.error
      • TaskResult.submitted_at
      • TaskResult.started_at
      • TaskResult.finished_at
      • TaskResult.retries
      • TaskResult.args
      • TaskResult.kwargs
      • TaskResult.is_complete
      • TaskResult.is_success
      • TaskResult.to_dict
      • TaskResult.from_dict()
      • TaskResult.__init__()
    • TaskStatus
      • TaskStatus.PENDING
      • TaskStatus.RUNNING
      • TaskStatus.SUCCESS
      • TaskStatus.FAILED
      • TaskStatus.RETRYING
    • FlowrraError
    • TaskNotFoundError
      • TaskNotFoundError.__init__()
    • TaskTimeoutError
      • TaskTimeoutError.__init__()
    • ExecutorNotRunningError
      • ExecutorNotRunningError.__init__()
    • BackendError