I have a DAG that looks like below, that gets executed via Cloud Composer. Its purpose is to extract data from an Oracle database. I try to have parametrized approach to the operator to avoid code duplication. The query is loaded from a GCS bucket and then I would expect that the parameters from it to be replace at runtime as specified in the operator.