Skip to content

Commit cc92681

Browse files
authored
add region tags (#5028)
1 parent ce793ce commit cc92681

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

composer/workflows/airflow_db_cleanup.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,8 @@
1111
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
14+
15+
# [START composer_metadb_cleanup]
1416
"""
1517
A maintenance workflow that you can deploy into Airflow to periodically clean
1618
out the DagRun, TaskInstance, Log, XCom, Job DB and SlaMiss entries to avoid
@@ -383,3 +385,5 @@ def cleanup_function(**context):
383385
dag=dag)
384386

385387
print_configuration.set_downstream(cleanup_op)
388+
389+
# [END composer_metadb_cleanup]

0 commit comments

Comments
 (0)