1. Advisor
  2. flowetl
  3. functions
  4. flowetl.flowetl.flowetl.mixins.wrapping_sql_mixin.WrappingSQLMixin
View all flowetl analysis

How to use the flowetl.flowetl.flowetl.mixins.wrapping_sql_mixin.WrappingSQLMixin function in flowetl

To help you get started, we’ve selected a few flowetl examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github Flowminder / FlowKit / flowetl / flowetl / flowetl / mixins / wrapping_sql_mixin.py View on Github external
class_name : str
        Class name for the operator
    sql : str
        SQL string to use as wrapper

    Returns
    -------
    Type

    """
    from flowetl.mixins.table_name_macros_mixin import TableNameMacrosMixin
    from airflow.operators.postgres_operator import PostgresOperator

    return type(
        class_name,
        (TableNameMacrosMixin, WrappingSQLMixin, PostgresOperator),
        dict(wrapper_sql=sql),
    )

flowetl

FlowETL is a collection of special purposes Airflow operators and sensors for use with FlowKit.

GitHub
MPL-2.0
Latest version published 2 months ago

Package Health Score

75 / 100
Full package analysis

Popular flowetl functions

Similar packages