---
title: "POST /flows"
method: POST
path: "/flows"
tags: ["flow"]
---

# POST /flows

`POST /flows`

## Request

- Base URL: `https://headless.dataddo.com/customer-api/v1`
- URL: `https://headless.dataddo.com/customer-api/v1/flows`
- Auth: none declared

Creates new flow

## Request body

- union
  - PostFlowAlloyDbInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string: DB table identifier Only applicable for certain $destinationType.
  - PostFlowAwsAuroraInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowAwsAuroraPgsqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowAwsGlueInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `table_id` string
  - PostFlowAwsRdsMariadbInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowAwsRdsMysqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowAwsRdsPgsqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowAwsRdsSqlServerInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowAzureBlobStorageInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowAzureSqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowAzureStorageInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowAzureSynapseInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowBrazeInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowClickhouseInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `table_engine` string
    - `charset` string
  - PostFlowCockroachDbInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowDataboxInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `data_source` string
    - `dataSourceLabel` string
    - `primaryKeys` string[]
  - PostFlowDatabricksInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowDevNullInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `latency` string
    - `latency_batch_size` integer
  - PostFlowDotdigitalInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
    - `address_book` string
  - PostFlowEmailInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `attachmentFormat` string
    - `subject` string
  - PostFlowExactOnlineInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowExasolInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowFirebirdInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowFireboltInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowFtpInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowGoogleAdsInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowGoogleBigQueryInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string: DB table identifier Only applicable for certain $destinationType.
    - `max_staleness` string, nullable: BigQuery table max_staleness for the native-CDC merge: a Go duration such as "15m". Empty means real-time. Only takes effect for CDC flows.
  - PostFlowGoogleCloudStorageInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowGoogleDriveInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowGoogleCloudMssqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowGoogleCloudMysqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowGoogleCloudPgsqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowGoogleSheetsInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `unique_columns` string[]
    - `spreadsheet_id` string: Spreadsheet identifier.
    - `spreadsheet_document_name` string, nullable: Spreadsheet document name.
    - `spreadsheet_sheet_name` string, nullable: Spreadsheet tab name.
    - `write_header` boolean: Whether to write header line or not.
  - PostFlowHubspotInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowIcebergRestInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `table_id` string
  - PostFlowInformixInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowKafkaInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
  - PostFlowKeboolaInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowKlaviyoInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowMariaDbInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowMembersApiInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
    - `year` string
    - `event` string
    - `attribute_option` string
    - `opted_in` string
  - PostFlowMetaConversionsInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowMicrosoftFabricInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowMicrosoftSharePointInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `format` 'json' | 'csv' | 'xml' | 'xlsx' | 'parquet' | 'jsonl'
    - `filename_pattern` string: Filename pattern.
    - `custom_filename_pattern` string, nullable
    - `csv_header` boolean: Add csv header on the first line or not.
    - `csv_nil_data_as_empty_string` boolean
    - `csv_custom_date_time_format` string, nullable
    - `csv_delimiter` string, nullable: CSV file delimiter.
    - `sheet_name` string, nullable: XLS/XLSX sheet name.
    - `parquet_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `json_omit_empty` boolean
    - `json_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
    - `jsonl_omit_empty` boolean
    - `jsonl_timestamp_unit` 'seconds' | 'microseconds' | 'nanoseconds' | 'milliseconds'
  - PostFlowMondayInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowMongoInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string: DB table identifier Only applicable for certain $destinationType.
  - PostFlowMongoAtlasInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string: DB table identifier Only applicable for certain $destinationType.
  - PostFlowMssqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
  - PostFlowMysqlInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `table_id` string
    - `charset` string
  - PostFlowNetsuiteInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
      - `unique` boolean
  - PostFlowOdooInput
    - `storage_id` string, nullable
    - `destination_id` string
    - `label` string
    - `sources` string[], nullable: List of sources to be used.
    - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
      - SqlQueryFlow
        - `query` string
        - `sources` SqlSourceMappingInput[]
          - `sourceId` string
          - `tableName` string
          - `columns` SqlColumnMappingInput[]
            - `columnId` string
            - `columnName` string
      - UnionFlow
        - `sources` UnionSourceInput[]
          - `sourceId` string
          - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
      - DirectSourceFlow
        - `sourceId` string
        - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
    - `rules` FlowDataQualityRuleDocument[]: List of Data Quality Rules.
      - `column_id` string
      - `rule` 'nils' | 'zeros' | 'anomaly'
      - `action` 'block' | 'email'
    - `stream` boolean, nullable
    - `load_immediately` boolean
    - `preceding_actions_policy` 'strict' | 'liberal'
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `mapping` FlowMappingInput[]
      - `source_column` string
      - `destination_column` string
- … truncated; see the full OpenAPI document linked below

## Response `200`

Creates new flow

- FlowDocument
  - `descriptors` Descriptor[]
    - `key` 'EMPTY' | 'DATABASE' | 'TABLE' | 'FILE' | 'FORMAT' | 'PATH' | 'WRITE_MODE' | 'SPREADSHEET_ID' | 'SPREADSHEET' | 'SHEET' | 'DATASET' | 'PROJECT' | 'SCHEMA' | 'TOPIC' | 'ACCOUNT' | 'TYPE' | 'REPORT' | 'GRANULARITY' | 'CHANNEL' | 'PROPERTY' | 'BUCKET'
    - `value` string: descriptor value
  - `external_id` string, nullable: The id of the document in external systems. By setting external_id you can link document with external systems id.
  - `is_locked` boolean: You may mark the document as locked to prevent accidental changes. When locked, the document cannot be modified or deleted.
  - `flow_type` 'fetch' | 'write'
  - `label` string
  - `customer_id` string
  - `sources` FlowSourceDocument[]
    - `source_id` string
  - `rules` FlowDataQualityRuleDocument[]
    - `column_id` string
    - `rule` 'nils' | 'zeros' | 'anomaly'
    - `action` 'block' | 'email'
  - `preceding_actions_policy` 'strict' | 'liberal'
  - `fetch_public_id` string, nullable
  - `created_at` integer
  - `updated_at` integer
  - `write_action` WriteActionDocument
    - `type` string
    - `object_id` string
    - `object_type` string
    - `status` 'live' | 'broken' | 'retrying' | 'running' | 'inactive' | 'cancelling' | 'cancelled'
    - `status_detail` string
    - `last_execution` integer, nullable: Last execution timestamp
    - `next_execution` integer, nullable: Next execution timestamp. Makes sense only for actions with schedule, otherwise it is null. It is computed and updated based on the schedule change or when action is executed.
    - `error_count` integer: Error iteration count
    - `is_being_processed` boolean: Is the action currently being processed?
    - `on_error_retry_timeout` integer: After how many seconds the action should be retried after failure. the value 0 means run retry just after. Example: set to 60*60*2 to retry action not earlier than 2hrs after failure
    - `schedule` object, nullable: Action Schedule settings
    - `created_at` integer
    - `updated_at` integer
    - `duration` string, nullable: Duration
    - `write_mode` 'insert' | 'insert_ignore' | 'truncate_insert' | 'upsert' | 'update' | 'update_ignore' | 'delete' | 'cdc'
    - `unique_columns` string[]: Array of strings.
    - `setup_instructions` string
  - `fdr_allowed` boolean
  - `destination_id` string
  - `stream` boolean
  - `flow_definition` union: FlowDefinition: exactly one of SqlQueryFlow, UnionFlow, or DirectSourceFlow.
    - SqlQueryFlow
      - `query` string
      - `sources` SqlSourceMappingInput[]
        - `sourceId` string
        - `tableName` string
        - `columns` SqlColumnMappingInput[]
          - `columnId` string
          - `columnName` string
    - UnionFlow
      - `sources` UnionSourceInput[]
        - `sourceId` string
        - `columnOrder` string[]: Optional per-source column order. If empty, inherits the source's natural column order.
    - DirectSourceFlow
      - `sourceId` string
      - `columnOrder` string[]: Optional per-flow column order. If empty, inherits the source's natural column order.
  - `source` FlowSourceDocument[]: Use sources instead.
    - `source_id` string

---

[API](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api.md) · [All operations](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api/llms.txt) · [OpenAPI document](https://skmtc.dev/dataddo/apis/dataddo-headless-beta-api/revisions/dcfa2345bd10?raw)