run a checkpoint based on SQL query with parameters modifying that query from Airflow

[kujaska]

I need to run a checkpoint based on SQL query with parameters modifying that query from Airflow

Part of checkpoint.yml looks like:

validations:

• batch_request:
  datasource_name: snowflake
  data_connector_name: default_runtime_data_connector_name
  data_asset_name: db1.table1
  runtime_parameters:
  query: "SELECT *
  from db1.table1
  WHERE fld1 > $PARAM_FROM_AIRFLOW"

How to do it properly with GreatExpectationsOperator?

Is passing query_to_validate the only/recommended option for the GreatExpectationsOperator?

Thanks!

[kujaska]

Workaround possible: set $PARAM_FROM_AIRFLOW as an environment variable - it will work, too