Create a new flow — pl_create

Registers a new flow in PocketBase. Errors if a flow with the same name already exists. Validates that depends_on flows exist and that adding them would not create a cycle in the DAG.

Usage

pl_create_flow(
  conn,
  name,
  type,
  description = NULL,
  schedule = NULL,
  depends_on = NULL
)

Arguments

conn: A connection object from pl_connect().
name: Unique flow identifier (e.g. "ectrl_data_load").
type: Flow type string. See pl_flow_types for defaults, but any string is accepted.
description: Optional human-readable description.
schedule: Optional cron expression or human-readable schedule string.
depends_on: Optional character vector of upstream flow names.

Value

Invisibly returns the created flow record as a list.

Examples

if (FALSE) { # \dontrun{
conn <- pl_connect()
pl_create_flow(conn, "ectrl_data_load", type = "data_job",
               description = "Daily EUROCONTROL data import",
               schedule = "0 6 * * *")
} # }