Skip to content

Commit 74557e4

Browse files
authored
Add exportContext.offload flag to CLOUD_SQL_EXPORT_VALIDATION. (#23614)
1 parent 1bd75dd commit 74557e4

File tree

3 files changed

+8
-1
lines changed

3 files changed

+8
-1
lines changed

airflow/providers/google/cloud/example_dags/example_cloud_sql.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,12 @@
123123
# [END howto_operator_cloudsql_patch_body]
124124
# [START howto_operator_cloudsql_export_body]
125125
export_body = {
126-
"exportContext": {"fileType": "sql", "uri": EXPORT_URI, "sqlExportOptions": {"schemaOnly": False}}
126+
"exportContext": {
127+
"fileType": "sql",
128+
"uri": EXPORT_URI,
129+
"sqlExportOptions": {"schemaOnly": False},
130+
"offload": True,
131+
}
127132
}
128133
# [END howto_operator_cloudsql_export_body]
129134
# [START howto_operator_cloudsql_import_body]

airflow/providers/google/cloud/operators/cloud_sql.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,7 @@
154154
],
155155
),
156156
dict(name="csvExportOptions", type="dict", optional=True, fields=[dict(name="selectQuery")]),
157+
dict(name="offload", optional=True),
157158
],
158159
)
159160
]

tests/providers/google/cloud/operators/test_cloud_sql.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,7 @@
123123
"databases": [],
124124
"sqlExportOptions": {"tables": ["table1", "table2"], "schemaOnly": False},
125125
"csvExportOptions": {"selectQuery": "SELECT * FROM TABLE"},
126+
"offload": True,
126127
}
127128
}
128129
IMPORT_BODY = {

0 commit comments

Comments
 (0)