Module flowmium::driver

source ·

Functions

  • get_default_executor_config
    Constructor executor config from environment variables. Environment variables that are expected to be set are fields of crate::executor::ExecutorConfig but in all caps prefixed with FLOWMIUM_.
  • get_default_postgres_pool
    Create a postgres connection pool object, create a table to store secrets and flow statuses and perform migration. The tables are flows and secrets respectively. An environment variable named FLOWMIUM_POSTGRES_URL with value as an URL to a postgres database is expected to be set.
  • run
    Parse CLI arguments and environment variables and run flowmium CLI.
  • run_api_server
    Run API server. This function does not return unless there is an error.
  • spawn_executor
    Spawn a tokio task that periodically calls crate::executor::schedule_and_run_tasks every second and makes progress on pending flows.