You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2022/09/19 13:28:15 UTC
[airflow] branch main updated: Add updated_at column to DagRun and Ti tables (#26252)
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 4930df45f5 Add updated_at column to DagRun and Ti tables (#26252)
4930df45f5 is described below
commit 4930df45f5bae89c297dbcd5cafc582a61a0f323
Author: pierrejeambrun <pi...@gmail.com>
AuthorDate: Mon Sep 19 15:28:07 2022 +0200
Add updated_at column to DagRun and Ti tables (#26252)
Updated following code review
Update migration version to 2.5.0
---
.../0118_2_5_0_add_updated_at_to_dagrun_and_ti.py | 57 ++
airflow/models/dagrun.py | 1 +
airflow/models/taskinstance.py | 1 +
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 898 +++++++++++----------
docs/apache-airflow/migrations-ref.rst | 4 +-
tests/models/test_taskinstance.py | 1 +
7 files changed, 516 insertions(+), 448 deletions(-)
diff --git a/airflow/migrations/versions/0118_2_5_0_add_updated_at_to_dagrun_and_ti.py b/airflow/migrations/versions/0118_2_5_0_add_updated_at_to_dagrun_and_ti.py
new file mode 100644
index 0000000000..fc58052965
--- /dev/null
+++ b/airflow/migrations/versions/0118_2_5_0_add_updated_at_to_dagrun_and_ti.py
@@ -0,0 +1,57 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+"""Add updated_at column to DagRun and TaskInstance
+
+Revision ID: ee8d93fcc81e
+Revises: ecb43d2a1842
+Create Date: 2022-09-08 19:08:37.623121
+
+"""
+
+from __future__ import annotations
+
+import sqlalchemy as sa
+from alembic import op
+
+from airflow.migrations.db_types import TIMESTAMP
+
+# revision identifiers, used by Alembic.
+revision = 'ee8d93fcc81e'
+down_revision = 'ecb43d2a1842'
+branch_labels = None
+depends_on = None
+airflow_version = '2.5.0'
+
+
+def upgrade():
+ """Apply add updated_at column to DagRun and TaskInstance"""
+ with op.batch_alter_table('task_instance') as batch_op:
+ batch_op.add_column(sa.Column('updated_at', TIMESTAMP, default=sa.func.now))
+
+ with op.batch_alter_table('dag_run') as batch_op:
+ batch_op.add_column(sa.Column('updated_at', TIMESTAMP, default=sa.func.now))
+
+
+def downgrade():
+ """Unapply add updated_at column to DagRun and TaskInstance"""
+ with op.batch_alter_table('task_instance') as batch_op:
+ batch_op.drop_column('updated_at')
+
+ with op.batch_alter_table('dag_run') as batch_op:
+ batch_op.drop_column('updated_at')
diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py
index 99d969ab19..ac98b1a32f 100644
--- a/airflow/models/dagrun.py
+++ b/airflow/models/dagrun.py
@@ -127,6 +127,7 @@ class DagRun(Base, LoggingMixin):
ForeignKey("log_template.id", name="task_instance_log_template_id_fkey", ondelete="NO ACTION"),
default=select([func.max(LogTemplate.__table__.c.id)]),
)
+ updated_at = Column(UtcDateTime, default=timezone.utcnow, onupdate=timezone.utcnow)
# Remove this `if` after upgrading Sphinx-AutoAPI
if not TYPE_CHECKING and "BUILDING_AIRFLOW_DOCS" in os.environ:
diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
index 5d9401d7f7..52562e72ad 100644
--- a/airflow/models/taskinstance.py
+++ b/airflow/models/taskinstance.py
@@ -452,6 +452,7 @@ class TaskInstance(Base, LoggingMixin):
queued_by_job_id = Column(Integer)
pid = Column(Integer)
executor_config = Column(ExecutorConfigType(pickler=dill))
+ updated_at = Column(UtcDateTime, default=timezone.utcnow, onupdate=timezone.utcnow)
external_executor_id = Column(StringID())
diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256
index eab880ad31..2cde8179cb 100644
--- a/docs/apache-airflow/img/airflow_erd.sha256
+++ b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-b3211bf16ef6ae93fc4a4cfeb2acffc0e2f3a8f476d76148d543f2751aff2c5d
\ No newline at end of file
+5b101dceaef5d9343cddbfab0db6087b646d031eb8a1c3157f79e6cd811e14f4
\ No newline at end of file
diff --git a/docs/apache-airflow/img/airflow_erd.svg b/docs/apache-airflow/img/airflow_erd.svg
index 76be963f0c..f113037c85 100644
--- a/docs/apache-airflow/img/airflow_erd.svg
+++ b/docs/apache-airflow/img/airflow_erd.svg
@@ -4,11 +4,11 @@
<!-- Generated by graphviz version 2.43.0 (0)
-->
<!-- Title: %3 Pages: 1 -->
-<svg width="1530pt" height="4683pt"
- viewBox="0.00 0.00 1530.00 4682.50" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink">
-<g id="graph0" class="graph" transform="scale(1 1) rotate(0) translate(4 4678.5)">
+<svg width="1530pt" height="4711pt"
+ viewBox="0.00 0.00 1530.00 4710.50" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink">
+<g id="graph0" class="graph" transform="scale(1 1) rotate(0) translate(4 4706.5)">
<title>%3</title>
-<polygon fill="white" stroke="transparent" points="-4,4 -4,-4678.5 1526,-4678.5 1526,4 -4,4"/>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-4706.5 1526,-4706.5 1526,4 -4,4"/>
<!-- ab_permission -->
<g id="node1" class="node">
<title>ab_permission</title>
@@ -576,233 +576,239 @@
<!-- dag_code -->
<g id="node19" class="node">
<title>dag_code</title>
-<polygon fill="none" stroke="black" points="55.5,-2603 55.5,-2631 327.5,-2631 327.5,-2603 55.5,-2603"/>
-<text text-anchor="start" x="149" y="-2614.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_code</text>
-<polygon fill="none" stroke="black" points="55.5,-2578 55.5,-2603 327.5,-2603 327.5,-2578 55.5,-2578"/>
-<text text-anchor="start" x="60.5" y="-2587.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">fileloc_hash</text>
-<text text-anchor="start" x="142.5" y="-2587.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
-<text text-anchor="start" x="206.5" y="-2587.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-2553 55.5,-2578 327.5,-2578 327.5,-2553 55.5,-2553"/>
-<text text-anchor="start" x="60.5" y="-2562.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
-<text text-anchor="start" x="101.5" y="-2562.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<text text-anchor="start" x="231.5" y="-2562.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-2528 55.5,-2553 327.5,-2553 327.5,-2528 55.5,-2528"/>
-<text text-anchor="start" x="60.5" y="-2537.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
-<text text-anchor="start" x="150.5" y="-2537.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="246.5" y="-2537.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-2503 55.5,-2528 327.5,-2528 327.5,-2503 55.5,-2503"/>
-<text text-anchor="start" x="60.5" y="-2512.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_code</text>
-<text text-anchor="start" x="146.5" y="-2512.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<text text-anchor="start" x="196.5" y="-2512.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-2621 55.5,-2649 327.5,-2649 327.5,-2621 55.5,-2621"/>
+<text text-anchor="start" x="149" y="-2632.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_code</text>
+<polygon fill="none" stroke="black" points="55.5,-2596 55.5,-2621 327.5,-2621 327.5,-2596 55.5,-2596"/>
+<text text-anchor="start" x="60.5" y="-2605.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">fileloc_hash</text>
+<text text-anchor="start" x="142.5" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
+<text text-anchor="start" x="206.5" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-2571 55.5,-2596 327.5,-2596 327.5,-2571 55.5,-2571"/>
+<text text-anchor="start" x="60.5" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
+<text text-anchor="start" x="101.5" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="231.5" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-2546 55.5,-2571 327.5,-2571 327.5,-2546 55.5,-2546"/>
+<text text-anchor="start" x="60.5" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
+<text text-anchor="start" x="150.5" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="246.5" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-2521 55.5,-2546 327.5,-2546 327.5,-2521 55.5,-2521"/>
+<text text-anchor="start" x="60.5" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_code</text>
+<text text-anchor="start" x="146.5" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="196.5" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_pickle -->
<g id="node20" class="node">
<title>dag_pickle</title>
-<polygon fill="none" stroke="black" points="92.5,-2772 92.5,-2800 290.5,-2800 290.5,-2772 92.5,-2772"/>
-<text text-anchor="start" x="144.5" y="-2783.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_pickle</text>
-<polygon fill="none" stroke="black" points="92.5,-2747 92.5,-2772 290.5,-2772 290.5,-2747 92.5,-2747"/>
-<text text-anchor="start" x="97.5" y="-2756.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="110.5" y="-2756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="187.5" y="-2756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="92.5,-2722 92.5,-2747 290.5,-2747 290.5,-2722 92.5,-2722"/>
-<text text-anchor="start" x="97.5" y="-2731.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_dttm</text>
-<text text-anchor="start" x="189.5" y="-2731.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="92.5,-2697 92.5,-2722 290.5,-2722 290.5,-2697 92.5,-2697"/>
-<text text-anchor="start" x="97.5" y="-2706.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle</text>
-<text text-anchor="start" x="138.5" y="-2706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
-<polygon fill="none" stroke="black" points="92.5,-2672 92.5,-2697 290.5,-2697 290.5,-2672 92.5,-2672"/>
-<text text-anchor="start" x="97.5" y="-2681.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle_hash</text>
-<text text-anchor="start" x="179.5" y="-2681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
+<polygon fill="none" stroke="black" points="92.5,-2796 92.5,-2824 290.5,-2824 290.5,-2796 92.5,-2796"/>
+<text text-anchor="start" x="144.5" y="-2807.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_pickle</text>
+<polygon fill="none" stroke="black" points="92.5,-2771 92.5,-2796 290.5,-2796 290.5,-2771 92.5,-2771"/>
+<text text-anchor="start" x="97.5" y="-2780.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="110.5" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="187.5" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="92.5,-2746 92.5,-2771 290.5,-2771 290.5,-2746 92.5,-2746"/>
+<text text-anchor="start" x="97.5" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_dttm</text>
+<text text-anchor="start" x="189.5" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="92.5,-2721 92.5,-2746 290.5,-2746 290.5,-2721 92.5,-2721"/>
+<text text-anchor="start" x="97.5" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle</text>
+<text text-anchor="start" x="138.5" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
+<polygon fill="none" stroke="black" points="92.5,-2696 92.5,-2721 290.5,-2721 290.5,-2696 92.5,-2696"/>
+<text text-anchor="start" x="97.5" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle_hash</text>
+<text text-anchor="start" x="179.5" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
</g>
<!-- dag_run -->
<g id="node21" class="node">
<title>dag_run</title>
-<polygon fill="none" stroke="black" points="472,-3095 472,-3123 759,-3123 759,-3095 472,-3095"/>
-<text text-anchor="start" x="579" y="-3106.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run</text>
-<polygon fill="none" stroke="black" points="472,-3070 472,-3095 759,-3095 759,-3070 472,-3070"/>
-<text text-anchor="start" x="477" y="-3079.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="490" y="-3079.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="567" y="-3079.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="472,-3045 472,-3070 759,-3070 759,-3045 472,-3045"/>
-<text text-anchor="start" x="477" y="-3054.8" font-family="Helvetica,sans-Serif" font-size="14.00">conf</text>
-<text text-anchor="start" x="508" y="-3054.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
-<polygon fill="none" stroke="black" points="472,-3020 472,-3045 759,-3045 759,-3020 472,-3020"/>
-<text text-anchor="start" x="477" y="-3029.8" font-family="Helvetica,sans-Serif" font-size="14.00">creating_job_id</text>
-<text text-anchor="start" x="581" y="-3029.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="472,-2995 472,-3020 759,-3020 759,-2995 472,-2995"/>
-<text text-anchor="start" x="477" y="-3004.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
-<text text-anchor="start" x="544" y="-3004.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
-<polygon fill="none" stroke="black" points="472,-2970 472,-2995 759,-2995 759,-2970 472,-2970"/>
-<text text-anchor="start" x="477" y="-2979.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="523" y="-2979.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="644" y="-2979.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="472,-2945 472,-2970 759,-2970 759,-2945 472,-2945"/>
-<text text-anchor="start" x="477" y="-2954.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_end</text>
-<text text-anchor="start" x="601" y="-2954.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2920 472,-2945 759,-2945 759,-2920 472,-2920"/>
-<text text-anchor="start" x="477" y="-2929.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_start</text>
-<text text-anchor="start" x="607" y="-2929.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2895 472,-2920 759,-2920 759,-2895 472,-2895"/>
-<text text-anchor="start" x="477" y="-2904.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="541" y="-2904.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2870 472,-2895 759,-2895 759,-2870 472,-2870"/>
-<text text-anchor="start" x="477" y="-2879.8" font-family="Helvetica,sans-Serif" font-size="14.00">execution_date</text>
-<text text-anchor="start" x="582" y="-2879.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="678" y="-2879.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="472,-2845 472,-2870 759,-2870 759,-2845 472,-2845"/>
-<text text-anchor="start" x="477" y="-2854.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_trigger</text>
-<text text-anchor="start" x="588" y="-2854.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="472,-2820 472,-2845 759,-2845 759,-2820 472,-2820"/>
-<text text-anchor="start" x="477" y="-2829.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_scheduling_decision</text>
-<text text-anchor="start" x="649" y="-2829.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2795 472,-2820 759,-2820 759,-2795 472,-2795"/>
-<text text-anchor="start" x="477" y="-2804.8" font-family="Helvetica,sans-Serif" font-size="14.00">log_template_id</text>
-<text text-anchor="start" x="586" y="-2804.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="472,-2770 472,-2795 759,-2795 759,-2770 472,-2770"/>
-<text text-anchor="start" x="477" y="-2779.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_at</text>
-<text text-anchor="start" x="550" y="-2779.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2745 472,-2770 759,-2770 759,-2745 472,-2745"/>
-<text text-anchor="start" x="477" y="-2754.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="521" y="-2754.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="642" y="-2754.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="472,-2720 472,-2745 759,-2745 759,-2720 472,-2720"/>
-<text text-anchor="start" x="477" y="-2729.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_type</text>
-<text text-anchor="start" x="539" y="-2729.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
-<text text-anchor="start" x="651" y="-2729.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="472,-2695 472,-2720 759,-2720 759,-2695 472,-2695"/>
-<text text-anchor="start" x="477" y="-2704.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="547" y="-2704.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="472,-2670 472,-2695 759,-2695 759,-2670 472,-2670"/>
-<text text-anchor="start" x="477" y="-2679.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="512" y="-2679.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<polygon fill="none" stroke="black" points="472,-3136 472,-3164 759,-3164 759,-3136 472,-3136"/>
+<text text-anchor="start" x="579" y="-3147.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run</text>
+<polygon fill="none" stroke="black" points="472,-3111 472,-3136 759,-3136 759,-3111 472,-3111"/>
+<text text-anchor="start" x="477" y="-3120.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="490" y="-3120.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="567" y="-3120.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="472,-3086 472,-3111 759,-3111 759,-3086 472,-3086"/>
+<text text-anchor="start" x="477" y="-3095.8" font-family="Helvetica,sans-Serif" font-size="14.00">conf</text>
+<text text-anchor="start" x="508" y="-3095.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
+<polygon fill="none" stroke="black" points="472,-3061 472,-3086 759,-3086 759,-3061 472,-3061"/>
+<text text-anchor="start" x="477" y="-3070.8" font-family="Helvetica,sans-Serif" font-size="14.00">creating_job_id</text>
+<text text-anchor="start" x="581" y="-3070.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="472,-3036 472,-3061 759,-3061 759,-3036 472,-3036"/>
+<text text-anchor="start" x="477" y="-3045.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
+<text text-anchor="start" x="544" y="-3045.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<polygon fill="none" stroke="black" points="472,-3011 472,-3036 759,-3036 759,-3011 472,-3011"/>
+<text text-anchor="start" x="477" y="-3020.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="523" y="-3020.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="644" y="-3020.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="472,-2986 472,-3011 759,-3011 759,-2986 472,-2986"/>
+<text text-anchor="start" x="477" y="-2995.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_end</text>
+<text text-anchor="start" x="601" y="-2995.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2961 472,-2986 759,-2986 759,-2961 472,-2961"/>
+<text text-anchor="start" x="477" y="-2970.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_start</text>
+<text text-anchor="start" x="607" y="-2970.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2936 472,-2961 759,-2961 759,-2936 472,-2936"/>
+<text text-anchor="start" x="477" y="-2945.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="541" y="-2945.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2911 472,-2936 759,-2936 759,-2911 472,-2911"/>
+<text text-anchor="start" x="477" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00">execution_date</text>
+<text text-anchor="start" x="582" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="678" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="472,-2886 472,-2911 759,-2911 759,-2886 472,-2886"/>
+<text text-anchor="start" x="477" y="-2895.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_trigger</text>
+<text text-anchor="start" x="588" y="-2895.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<polygon fill="none" stroke="black" points="472,-2861 472,-2886 759,-2886 759,-2861 472,-2861"/>
+<text text-anchor="start" x="477" y="-2870.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_scheduling_decision</text>
+<text text-anchor="start" x="649" y="-2870.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2836 472,-2861 759,-2861 759,-2836 472,-2836"/>
+<text text-anchor="start" x="477" y="-2845.8" font-family="Helvetica,sans-Serif" font-size="14.00">log_template_id</text>
+<text text-anchor="start" x="586" y="-2845.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="472,-2811 472,-2836 759,-2836 759,-2811 472,-2811"/>
+<text text-anchor="start" x="477" y="-2820.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_at</text>
+<text text-anchor="start" x="550" y="-2820.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2786 472,-2811 759,-2811 759,-2786 472,-2786"/>
+<text text-anchor="start" x="477" y="-2795.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="521" y="-2795.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="642" y="-2795.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="472,-2761 472,-2786 759,-2786 759,-2761 472,-2761"/>
+<text text-anchor="start" x="477" y="-2770.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_type</text>
+<text text-anchor="start" x="539" y="-2770.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<text text-anchor="start" x="651" y="-2770.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="472,-2736 472,-2761 759,-2761 759,-2736 472,-2736"/>
+<text text-anchor="start" x="477" y="-2745.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="547" y="-2745.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="472,-2711 472,-2736 759,-2736 759,-2711 472,-2711"/>
+<text text-anchor="start" x="477" y="-2720.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="512" y="-2720.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<polygon fill="none" stroke="black" points="472,-2686 472,-2711 759,-2711 759,-2686 472,-2686"/>
+<text text-anchor="start" x="477" y="-2695.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="556" y="-2695.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- dagrun_dataset_event -->
<g id="node22" class="node">
<title>dagrun_dataset_event</title>
-<polygon fill="none" stroke="black" points="872,-3207 872,-3235 1112,-3235 1112,-3207 872,-3207"/>
-<text text-anchor="start" x="892.5" y="-3218.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_dataset_event</text>
-<polygon fill="none" stroke="black" points="872,-3182 872,-3207 1112,-3207 1112,-3182 872,-3182"/>
-<text text-anchor="start" x="877" y="-3191.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="954" y="-3191.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1031" y="-3191.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="872,-3157 872,-3182 1112,-3182 1112,-3157 872,-3157"/>
-<text text-anchor="start" x="877" y="-3166.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
-<text text-anchor="start" x="936" y="-3166.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1013" y="-3166.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="872,-3242 872,-3270 1112,-3270 1112,-3242 872,-3242"/>
+<text text-anchor="start" x="892.5" y="-3253.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_dataset_event</text>
+<polygon fill="none" stroke="black" points="872,-3217 872,-3242 1112,-3242 1112,-3217 872,-3217"/>
+<text text-anchor="start" x="877" y="-3226.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="954" y="-3226.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1031" y="-3226.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="872,-3192 872,-3217 1112,-3217 1112,-3192 872,-3192"/>
+<text text-anchor="start" x="877" y="-3201.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
+<text text-anchor="start" x="936" y="-3201.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1013" y="-3201.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_run--dagrun_dataset_event -->
<g id="edge15" class="edge">
<title>dag_run--dagrun_dataset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-3017.11C826.71,-3065.01 892.04,-3117.1 936.63,-3152.65"/>
-<text text-anchor="start" x="905.63" y="-3141.45" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.64" y="-3005.91" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-3047.92C827.32,-3097.44 893.37,-3151.33 937.98,-3187.74"/>
+<text text-anchor="start" x="906.98" y="-3176.54" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.64" y="-3036.72" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- task_instance -->
<g id="node23" class="node">
<title>task_instance</title>
-<polygon fill="none" stroke="black" points="855,-2864 855,-2892 1129,-2892 1129,-2864 855,-2864"/>
-<text text-anchor="start" x="930.5" y="-2875.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
-<polygon fill="none" stroke="black" points="855,-2839 855,-2864 1129,-2864 1129,-2839 855,-2839"/>
-<text text-anchor="start" x="860" y="-2848.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="906" y="-2848.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1027" y="-2848.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2814 855,-2839 1129,-2839 1129,-2814 855,-2814"/>
-<text text-anchor="start" x="860" y="-2823.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="936" y="-2823.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1013" y="-2823.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2789 855,-2814 1129,-2814 1129,-2789 855,-2789"/>
-<text text-anchor="start" x="860" y="-2798.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="904" y="-2798.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1025" y="-2798.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2764 855,-2789 1129,-2789 1129,-2764 855,-2764"/>
-<text text-anchor="start" x="860" y="-2773.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="909" y="-2773.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1030" y="-2773.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2739 855,-2764 1129,-2764 1129,-2739 855,-2739"/>
-<text text-anchor="start" x="860" y="-2748.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="919" y="-2748.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [FLOAT]</text>
-<polygon fill="none" stroke="black" points="855,-2714 855,-2739 1129,-2739 1129,-2714 855,-2714"/>
-<text text-anchor="start" x="860" y="-2723.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="924" y="-2723.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855,-2689 855,-2714 1129,-2714 1129,-2689 855,-2689"/>
-<text text-anchor="start" x="860" y="-2698.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
-<text text-anchor="start" x="970" y="-2698.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
-<polygon fill="none" stroke="black" points="855,-2664 855,-2689 1129,-2689 1129,-2664 855,-2664"/>
-<text text-anchor="start" x="860" y="-2673.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
-<text text-anchor="start" x="1003" y="-2673.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="855,-2639 855,-2664 1129,-2664 1129,-2639 855,-2639"/>
-<text text-anchor="start" x="860" y="-2648.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
-<text text-anchor="start" x="930" y="-2648.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855,-2614 855,-2639 1129,-2639 1129,-2614 855,-2614"/>
-<text text-anchor="start" x="860" y="-2623.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_id</text>
-<text text-anchor="start" x="901" y="-2623.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2589 855,-2614 1129,-2614 1129,-2589 855,-2589"/>
-<text text-anchor="start" x="860" y="-2598.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
-<text text-anchor="start" x="928" y="-2598.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2564 855,-2589 1129,-2589 1129,-2564 855,-2564"/>
-<text text-anchor="start" x="860" y="-2573.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
-<text text-anchor="start" x="948" y="-2573.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="855,-2539 855,-2564 1129,-2564 1129,-2539 855,-2539"/>
-<text text-anchor="start" x="860" y="-2548.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
-<text text-anchor="start" x="951" y="-2548.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855,-2514 855,-2539 1129,-2539 1129,-2514 855,-2514"/>
-<text text-anchor="start" x="860" y="-2523.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
-<text text-anchor="start" x="920" y="-2523.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855,-2489 855,-2514 1129,-2514 1129,-2489 855,-2489"/>
-<text text-anchor="start" x="860" y="-2498.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
-<text text-anchor="start" x="882" y="-2498.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2464 855,-2489 1129,-2489 1129,-2464 855,-2464"/>
-<text text-anchor="start" x="860" y="-2473.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
-<text text-anchor="start" x="890" y="-2473.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<text text-anchor="start" x="1011" y="-2473.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2439 855,-2464 1129,-2464 1129,-2439 855,-2439"/>
-<text text-anchor="start" x="860" y="-2448.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
-<text text-anchor="start" x="929" y="-2448.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1006" y="-2448.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855,-2414 855,-2439 1129,-2439 1129,-2414 855,-2414"/>
-<text text-anchor="start" x="860" y="-2423.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
-<text text-anchor="start" x="964" y="-2423.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2389 855,-2414 1129,-2414 1129,-2389 855,-2389"/>
-<text text-anchor="start" x="860" y="-2398.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
-<text text-anchor="start" x="904" y="-2398.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<polygon fill="none" stroke="black" points="855,-2364 855,-2389 1129,-2389 1129,-2364 855,-2364"/>
-<text text-anchor="start" x="860" y="-2373.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
-<text text-anchor="start" x="984" y="-2373.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2339 855,-2364 1129,-2364 1129,-2339 855,-2339"/>
-<text text-anchor="start" x="860" y="-2348.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
-<text text-anchor="start" x="953" y="-2348.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855,-2314 855,-2339 1129,-2339 1129,-2314 855,-2314"/>
-<text text-anchor="start" x="860" y="-2323.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="930" y="-2323.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855,-2289 855,-2314 1129,-2314 1129,-2289 855,-2289"/>
-<text text-anchor="start" x="860" y="-2298.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="895" y="-2298.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
-<polygon fill="none" stroke="black" points="855,-2264 855,-2289 1129,-2289 1129,-2264 855,-2264"/>
-<text text-anchor="start" x="860" y="-2273.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
-<text text-anchor="start" x="927" y="-2273.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2239 855,-2264 1129,-2264 1129,-2239 855,-2239"/>
-<text text-anchor="start" x="860" y="-2248.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
-<text text-anchor="start" x="968" y="-2248.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DATETIME]</text>
-<polygon fill="none" stroke="black" points="855,-2214 855,-2239 1129,-2239 1129,-2214 855,-2214"/>
-<text text-anchor="start" x="860" y="-2223.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="942" y="-2223.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855,-2189 855,-2214 1129,-2214 1129,-2189 855,-2189"/>
-<text text-anchor="start" x="860" y="-2198.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
-<text text-anchor="start" x="930" y="-2198.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855,-2877 855,-2905 1129,-2905 1129,-2877 855,-2877"/>
+<text text-anchor="start" x="930.5" y="-2888.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
+<polygon fill="none" stroke="black" points="855,-2852 855,-2877 1129,-2877 1129,-2852 855,-2852"/>
+<text text-anchor="start" x="860" y="-2861.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="906" y="-2861.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1027" y="-2861.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2827 855,-2852 1129,-2852 1129,-2827 855,-2827"/>
+<text text-anchor="start" x="860" y="-2836.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="936" y="-2836.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1013" y="-2836.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2802 855,-2827 1129,-2827 1129,-2802 855,-2802"/>
+<text text-anchor="start" x="860" y="-2811.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="904" y="-2811.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1025" y="-2811.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2777 855,-2802 1129,-2802 1129,-2777 855,-2777"/>
+<text text-anchor="start" x="860" y="-2786.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="909" y="-2786.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1030" y="-2786.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2752 855,-2777 1129,-2777 1129,-2752 855,-2752"/>
+<text text-anchor="start" x="860" y="-2761.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="919" y="-2761.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [FLOAT]</text>
+<polygon fill="none" stroke="black" points="855,-2727 855,-2752 1129,-2752 1129,-2727 855,-2727"/>
+<text text-anchor="start" x="860" y="-2736.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="924" y="-2736.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855,-2702 855,-2727 1129,-2727 1129,-2702 855,-2702"/>
+<text text-anchor="start" x="860" y="-2711.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
+<text text-anchor="start" x="970" y="-2711.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
+<polygon fill="none" stroke="black" points="855,-2677 855,-2702 1129,-2702 1129,-2677 855,-2677"/>
+<text text-anchor="start" x="860" y="-2686.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
+<text text-anchor="start" x="1003" y="-2686.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="855,-2652 855,-2677 1129,-2677 1129,-2652 855,-2652"/>
+<text text-anchor="start" x="860" y="-2661.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
+<text text-anchor="start" x="930" y="-2661.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855,-2627 855,-2652 1129,-2652 1129,-2627 855,-2627"/>
+<text text-anchor="start" x="860" y="-2636.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_id</text>
+<text text-anchor="start" x="901" y="-2636.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2602 855,-2627 1129,-2627 1129,-2602 855,-2602"/>
+<text text-anchor="start" x="860" y="-2611.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
+<text text-anchor="start" x="928" y="-2611.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2577 855,-2602 1129,-2602 1129,-2577 855,-2577"/>
+<text text-anchor="start" x="860" y="-2586.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
+<text text-anchor="start" x="948" y="-2586.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="855,-2552 855,-2577 1129,-2577 1129,-2552 855,-2552"/>
+<text text-anchor="start" x="860" y="-2561.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
+<text text-anchor="start" x="951" y="-2561.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855,-2527 855,-2552 1129,-2552 1129,-2527 855,-2527"/>
+<text text-anchor="start" x="860" y="-2536.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
+<text text-anchor="start" x="920" y="-2536.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855,-2502 855,-2527 1129,-2527 1129,-2502 855,-2502"/>
+<text text-anchor="start" x="860" y="-2511.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
+<text text-anchor="start" x="882" y="-2511.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2477 855,-2502 1129,-2502 1129,-2477 855,-2477"/>
+<text text-anchor="start" x="860" y="-2486.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
+<text text-anchor="start" x="890" y="-2486.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<text text-anchor="start" x="1011" y="-2486.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2452 855,-2477 1129,-2477 1129,-2452 855,-2452"/>
+<text text-anchor="start" x="860" y="-2461.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
+<text text-anchor="start" x="929" y="-2461.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1006" y="-2461.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855,-2427 855,-2452 1129,-2452 1129,-2427 855,-2427"/>
+<text text-anchor="start" x="860" y="-2436.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
+<text text-anchor="start" x="964" y="-2436.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2402 855,-2427 1129,-2427 1129,-2402 855,-2402"/>
+<text text-anchor="start" x="860" y="-2411.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
+<text text-anchor="start" x="904" y="-2411.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<polygon fill="none" stroke="black" points="855,-2377 855,-2402 1129,-2402 1129,-2377 855,-2377"/>
+<text text-anchor="start" x="860" y="-2386.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
+<text text-anchor="start" x="984" y="-2386.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2352 855,-2377 1129,-2377 1129,-2352 855,-2352"/>
+<text text-anchor="start" x="860" y="-2361.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
+<text text-anchor="start" x="953" y="-2361.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855,-2327 855,-2352 1129,-2352 1129,-2327 855,-2327"/>
+<text text-anchor="start" x="860" y="-2336.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="930" y="-2336.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855,-2302 855,-2327 1129,-2327 1129,-2302 855,-2302"/>
+<text text-anchor="start" x="860" y="-2311.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="895" y="-2311.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
+<polygon fill="none" stroke="black" points="855,-2277 855,-2302 1129,-2302 1129,-2277 855,-2277"/>
+<text text-anchor="start" x="860" y="-2286.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
+<text text-anchor="start" x="927" y="-2286.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2252 855,-2277 1129,-2277 1129,-2252 855,-2252"/>
+<text text-anchor="start" x="860" y="-2261.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
+<text text-anchor="start" x="968" y="-2261.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DATETIME]</text>
+<polygon fill="none" stroke="black" points="855,-2227 855,-2252 1129,-2252 1129,-2227 855,-2227"/>
+<text text-anchor="start" x="860" y="-2236.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="942" y="-2236.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855,-2202 855,-2227 1129,-2227 1129,-2202 855,-2202"/>
+<text text-anchor="start" x="860" y="-2211.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
+<text text-anchor="start" x="930" y="-2211.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855,-2177 855,-2202 1129,-2202 1129,-2177 855,-2177"/>
+<text text-anchor="start" x="860" y="-2186.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="939" y="-2186.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- dag_run--task_instance -->
<g id="edge16" class="edge">
<title>dag_run--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-2747.36C793.11,-2722.06 820.6,-2695.97 846.89,-2671.22"/>
-<text text-anchor="start" x="815.89" y="-2660.02" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.64" y="-2736.16" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-2764.12C793.11,-2736.84 820.6,-2708.7 846.89,-2681.98"/>
+<text text-anchor="start" x="815.89" y="-2670.78" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.64" y="-2752.92" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- dag_run--task_instance -->
<g id="edge17" class="edge">
<title>dag_run--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-2760.63C793.11,-2735.67 820.6,-2709.55 846.89,-2684.39"/>
-<text text-anchor="start" x="815.89" y="-2688.19" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.64" y="-2764.43" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.64,-2777.38C793.11,-2750.44 820.6,-2722.27 846.89,-2695.15"/>
+<text text-anchor="start" x="815.89" y="-2698.95" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.64" y="-2781.18" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- task_reschedule -->
<g id="node24" class="node">
@@ -853,16 +859,16 @@
<!-- dag_run--task_reschedule -->
<g id="edge18" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.67,-2917.01C895.36,-2937.23 1079.75,-2968.48 1209.74,-2992.08"/>
-<text text-anchor="start" x="1178.74" y="-2980.88" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.67" y="-2905.81" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.67,-2939.38C895.36,-2954.79 1079.75,-2979.14 1209.74,-2997.88"/>
+<text text-anchor="start" x="1178.74" y="-2986.68" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.67" y="-2928.18" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- dag_run--task_reschedule -->
<g id="edge19" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.67,-2928.09C895.36,-2951.5 1079.75,-2982.79 1209.74,-3003.27"/>
-<text text-anchor="start" x="1178.74" y="-3007.07" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.67" y="-2931.89" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.67,-2950.45C895.36,-2969.06 1079.75,-2993.45 1209.74,-3009.07"/>
+<text text-anchor="start" x="1178.74" y="-3012.87" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.67" y="-2954.25" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge37" class="edge">
@@ -1137,31 +1143,31 @@
<!-- log_template -->
<g id="node25" class="node">
<title>log_template</title>
-<polygon fill="none" stroke="black" points="64.5,-2933 64.5,-2961 319.5,-2961 319.5,-2933 64.5,-2933"/>
-<text text-anchor="start" x="134" y="-2944.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">log_template</text>
-<polygon fill="none" stroke="black" points="64.5,-2908 64.5,-2933 319.5,-2933 319.5,-2908 64.5,-2908"/>
-<text text-anchor="start" x="69.5" y="-2917.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="82.5" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="159.5" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="64.5,-2883 64.5,-2908 319.5,-2908 319.5,-2883 64.5,-2883"/>
-<text text-anchor="start" x="69.5" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="142.5" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="238.5" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="64.5,-2858 64.5,-2883 319.5,-2883 319.5,-2858 64.5,-2858"/>
-<text text-anchor="start" x="69.5" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00">elasticsearch_id</text>
-<text text-anchor="start" x="179.5" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<text text-anchor="start" x="229.5" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="64.5,-2833 64.5,-2858 319.5,-2858 319.5,-2833 64.5,-2833"/>
-<text text-anchor="start" x="69.5" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
-<text text-anchor="start" x="130.5" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<text text-anchor="start" x="180.5" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="64.5,-2961 64.5,-2989 319.5,-2989 319.5,-2961 64.5,-2961"/>
+<text text-anchor="start" x="134" y="-2972.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">log_template</text>
+<polygon fill="none" stroke="black" points="64.5,-2936 64.5,-2961 319.5,-2961 319.5,-2936 64.5,-2936"/>
+<text text-anchor="start" x="69.5" y="-2945.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="82.5" y="-2945.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="159.5" y="-2945.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="64.5,-2911 64.5,-2936 319.5,-2936 319.5,-2911 64.5,-2911"/>
+<text text-anchor="start" x="69.5" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="142.5" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="238.5" y="-2920.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="64.5,-2886 64.5,-2911 319.5,-2911 319.5,-2886 64.5,-2886"/>
+<text text-anchor="start" x="69.5" y="-2895.8" font-family="Helvetica,sans-Serif" font-size="14.00">elasticsearch_id</text>
+<text text-anchor="start" x="179.5" y="-2895.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="229.5" y="-2895.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="64.5,-2861 64.5,-2886 319.5,-2886 319.5,-2861 64.5,-2861"/>
+<text text-anchor="start" x="69.5" y="-2870.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
+<text text-anchor="start" x="130.5" y="-2870.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="180.5" y="-2870.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- log_template--dag_run -->
<g id="edge20" class="edge">
<title>log_template--dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M327.02,-2897C370.39,-2897 418.73,-2897 463.2,-2897"/>
-<text text-anchor="start" x="432.2" y="-2885.8" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="327.02" y="-2885.8" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M327.02,-2925C370.39,-2925 418.73,-2925 463.2,-2925"/>
+<text text-anchor="start" x="432.2" y="-2913.8" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="327.02" y="-2913.8" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- dataset -->
<g id="node26" class="node">
@@ -1213,133 +1219,133 @@
<!-- dataset_event -->
<g id="node27" class="node">
<title>dataset_event</title>
-<polygon fill="none" stroke="black" points="487,-3350 487,-3378 744,-3378 744,-3350 487,-3350"/>
-<text text-anchor="start" x="552" y="-3361.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset_event</text>
-<polygon fill="none" stroke="black" points="487,-3325 487,-3350 744,-3350 744,-3325 487,-3325"/>
-<text text-anchor="start" x="492" y="-3334.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="505" y="-3334.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="582" y="-3334.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="487,-3300 487,-3325 744,-3325 744,-3300 487,-3300"/>
-<text text-anchor="start" x="492" y="-3309.8" font-family="Helvetica,sans-Serif" font-size="14.00">dataset_id</text>
-<text text-anchor="start" x="564" y="-3309.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="641" y="-3309.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="487,-3275 487,-3300 744,-3300 744,-3275 487,-3275"/>
-<text text-anchor="start" x="492" y="-3284.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
-<text text-anchor="start" x="529" y="-3284.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<text text-anchor="start" x="580" y="-3284.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="487,-3250 487,-3275 744,-3275 744,-3250 487,-3250"/>
-<text text-anchor="start" x="492" y="-3259.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_dag_id</text>
-<text text-anchor="start" x="591" y="-3259.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="487,-3225 487,-3250 744,-3250 744,-3225 487,-3225"/>
-<text text-anchor="start" x="492" y="-3234.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_map_index</text>
-<text text-anchor="start" x="621" y="-3234.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="487,-3200 487,-3225 744,-3225 744,-3200 487,-3200"/>
-<text text-anchor="start" x="492" y="-3209.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_run_id</text>
-<text text-anchor="start" x="589" y="-3209.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="487,-3175 487,-3200 744,-3200 744,-3175 487,-3175"/>
-<text text-anchor="start" x="492" y="-3184.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_task_id</text>
-<text text-anchor="start" x="594" y="-3184.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="487,-3150 487,-3175 744,-3175 744,-3150 487,-3150"/>
-<text text-anchor="start" x="492" y="-3159.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="567" y="-3159.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="663" y="-3159.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="487,-3390 487,-3418 744,-3418 744,-3390 487,-3390"/>
+<text text-anchor="start" x="552" y="-3401.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset_event</text>
+<polygon fill="none" stroke="black" points="487,-3365 487,-3390 744,-3390 744,-3365 487,-3365"/>
+<text text-anchor="start" x="492" y="-3374.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="505" y="-3374.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="582" y="-3374.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="487,-3340 487,-3365 744,-3365 744,-3340 487,-3340"/>
+<text text-anchor="start" x="492" y="-3349.8" font-family="Helvetica,sans-Serif" font-size="14.00">dataset_id</text>
+<text text-anchor="start" x="564" y="-3349.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="641" y="-3349.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="487,-3315 487,-3340 744,-3340 744,-3315 487,-3315"/>
+<text text-anchor="start" x="492" y="-3324.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
+<text text-anchor="start" x="529" y="-3324.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<text text-anchor="start" x="580" y="-3324.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="487,-3290 487,-3315 744,-3315 744,-3290 487,-3290"/>
+<text text-anchor="start" x="492" y="-3299.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_dag_id</text>
+<text text-anchor="start" x="591" y="-3299.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="487,-3265 487,-3290 744,-3290 744,-3265 487,-3265"/>
+<text text-anchor="start" x="492" y="-3274.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_map_index</text>
+<text text-anchor="start" x="621" y="-3274.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="487,-3240 487,-3265 744,-3265 744,-3240 487,-3240"/>
+<text text-anchor="start" x="492" y="-3249.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_run_id</text>
+<text text-anchor="start" x="589" y="-3249.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="487,-3215 487,-3240 744,-3240 744,-3215 487,-3215"/>
+<text text-anchor="start" x="492" y="-3224.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_task_id</text>
+<text text-anchor="start" x="594" y="-3224.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="487,-3190 487,-3215 744,-3215 744,-3190 487,-3190"/>
+<text text-anchor="start" x="492" y="-3199.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="567" y="-3199.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="663" y="-3199.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dataset_event--dagrun_dataset_event -->
<g id="edge24" class="edge">
<title>dataset_event--dagrun_dataset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M751.65,-3239.4C788.24,-3232.77 827.69,-3225.61 863.81,-3219.06"/>
-<text text-anchor="start" x="832.81" y="-3207.86" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="751.65" y="-3228.2" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M751.65,-3277.59C788.24,-3270.47 827.69,-3262.79 863.81,-3255.76"/>
+<text text-anchor="start" x="832.81" y="-3244.56" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="751.65" y="-3266.39" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- import_error -->
<g id="node28" class="node">
<title>import_error</title>
-<polygon fill="none" stroke="black" points="91.5,-3087 91.5,-3115 292.5,-3115 292.5,-3087 91.5,-3087"/>
-<text text-anchor="start" x="134.5" y="-3098.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">import_error</text>
-<polygon fill="none" stroke="black" points="91.5,-3062 91.5,-3087 292.5,-3087 292.5,-3062 91.5,-3062"/>
-<text text-anchor="start" x="96.5" y="-3071.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="109.5" y="-3071.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="186.5" y="-3071.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="91.5,-3037 91.5,-3062 292.5,-3062 292.5,-3037 91.5,-3037"/>
-<text text-anchor="start" x="96.5" y="-3046.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
-<text text-anchor="start" x="157.5" y="-3046.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1024)]</text>
-<polygon fill="none" stroke="black" points="91.5,-3012 91.5,-3037 292.5,-3037 292.5,-3012 91.5,-3012"/>
-<text text-anchor="start" x="96.5" y="-3021.8" font-family="Helvetica,sans-Serif" font-size="14.00">stacktrace</text>
-<text text-anchor="start" x="169.5" y="-3021.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="91.5,-2987 91.5,-3012 292.5,-3012 292.5,-2987 91.5,-2987"/>
-<text text-anchor="start" x="96.5" y="-2996.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="171.5" y="-2996.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="91.5,-3115 91.5,-3143 292.5,-3143 292.5,-3115 91.5,-3115"/>
+<text text-anchor="start" x="134.5" y="-3126.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">import_error</text>
+<polygon fill="none" stroke="black" points="91.5,-3090 91.5,-3115 292.5,-3115 292.5,-3090 91.5,-3090"/>
+<text text-anchor="start" x="96.5" y="-3099.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="109.5" y="-3099.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="186.5" y="-3099.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="91.5,-3065 91.5,-3090 292.5,-3090 292.5,-3065 91.5,-3065"/>
+<text text-anchor="start" x="96.5" y="-3074.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
+<text text-anchor="start" x="157.5" y="-3074.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1024)]</text>
+<polygon fill="none" stroke="black" points="91.5,-3040 91.5,-3065 292.5,-3065 292.5,-3040 91.5,-3040"/>
+<text text-anchor="start" x="96.5" y="-3049.8" font-family="Helvetica,sans-Serif" font-size="14.00">stacktrace</text>
+<text text-anchor="start" x="169.5" y="-3049.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="91.5,-3015 91.5,-3040 292.5,-3040 292.5,-3015 91.5,-3015"/>
+<text text-anchor="start" x="96.5" y="-3024.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="171.5" y="-3024.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- job -->
<g id="node29" class="node">
<title>job</title>
-<polygon fill="none" stroke="black" points="75.5,-3391 75.5,-3419 308.5,-3419 308.5,-3391 75.5,-3391"/>
-<text text-anchor="start" x="178" y="-3402.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">job</text>
-<polygon fill="none" stroke="black" points="75.5,-3366 75.5,-3391 308.5,-3391 308.5,-3366 75.5,-3366"/>
-<text text-anchor="start" x="80.5" y="-3375.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="93.5" y="-3375.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="170.5" y="-3375.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="75.5,-3341 75.5,-3366 308.5,-3366 308.5,-3341 75.5,-3341"/>
-<text text-anchor="start" x="80.5" y="-3350.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="126.5" y="-3350.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="75.5,-3316 75.5,-3341 308.5,-3341 308.5,-3316 75.5,-3316"/>
-<text text-anchor="start" x="80.5" y="-3325.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="144.5" y="-3325.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="75.5,-3291 75.5,-3316 308.5,-3316 308.5,-3291 75.5,-3291"/>
-<text text-anchor="start" x="80.5" y="-3300.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_class</text>
-<text text-anchor="start" x="182.5" y="-3300.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
-<polygon fill="none" stroke="black" points="75.5,-3266 75.5,-3291 308.5,-3291 308.5,-3266 75.5,-3266"/>
-<text text-anchor="start" x="80.5" y="-3275.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
-<text text-anchor="start" x="150.5" y="-3275.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
-<polygon fill="none" stroke="black" points="75.5,-3241 75.5,-3266 308.5,-3266 308.5,-3241 75.5,-3241"/>
-<text text-anchor="start" x="80.5" y="-3250.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_type</text>
-<text text-anchor="start" x="139.5" y="-3250.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(30)]</text>
-<polygon fill="none" stroke="black" points="75.5,-3216 75.5,-3241 308.5,-3241 308.5,-3216 75.5,-3216"/>
-<text text-anchor="start" x="80.5" y="-3225.8" font-family="Helvetica,sans-Serif" font-size="14.00">latest_heartbeat</text>
-<text text-anchor="start" x="193.5" y="-3225.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="75.5,-3191 75.5,-3216 308.5,-3216 308.5,-3191 75.5,-3191"/>
-<text text-anchor="start" x="80.5" y="-3200.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="150.5" y="-3200.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="75.5,-3166 75.5,-3191 308.5,-3191 308.5,-3166 75.5,-3166"/>
-<text text-anchor="start" x="80.5" y="-3175.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="115.5" y="-3175.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
-<polygon fill="none" stroke="black" points="75.5,-3141 75.5,-3166 308.5,-3166 308.5,-3141 75.5,-3141"/>
-<text text-anchor="start" x="80.5" y="-3150.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
-<text text-anchor="start" x="150.5" y="-3150.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3419 75.5,-3447 308.5,-3447 308.5,-3419 75.5,-3419"/>
+<text text-anchor="start" x="178" y="-3430.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">job</text>
+<polygon fill="none" stroke="black" points="75.5,-3394 75.5,-3419 308.5,-3419 308.5,-3394 75.5,-3394"/>
+<text text-anchor="start" x="80.5" y="-3403.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="93.5" y="-3403.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="170.5" y="-3403.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="75.5,-3369 75.5,-3394 308.5,-3394 308.5,-3369 75.5,-3369"/>
+<text text-anchor="start" x="80.5" y="-3378.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="126.5" y="-3378.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3344 75.5,-3369 308.5,-3369 308.5,-3344 75.5,-3344"/>
+<text text-anchor="start" x="80.5" y="-3353.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="144.5" y="-3353.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="75.5,-3319 75.5,-3344 308.5,-3344 308.5,-3319 75.5,-3319"/>
+<text text-anchor="start" x="80.5" y="-3328.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_class</text>
+<text text-anchor="start" x="182.5" y="-3328.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3294 75.5,-3319 308.5,-3319 308.5,-3294 75.5,-3294"/>
+<text text-anchor="start" x="80.5" y="-3303.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
+<text text-anchor="start" x="150.5" y="-3303.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3269 75.5,-3294 308.5,-3294 308.5,-3269 75.5,-3269"/>
+<text text-anchor="start" x="80.5" y="-3278.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_type</text>
+<text text-anchor="start" x="139.5" y="-3278.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(30)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3244 75.5,-3269 308.5,-3269 308.5,-3244 75.5,-3244"/>
+<text text-anchor="start" x="80.5" y="-3253.8" font-family="Helvetica,sans-Serif" font-size="14.00">latest_heartbeat</text>
+<text text-anchor="start" x="193.5" y="-3253.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="75.5,-3219 75.5,-3244 308.5,-3244 308.5,-3219 75.5,-3219"/>
+<text text-anchor="start" x="80.5" y="-3228.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="150.5" y="-3228.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="75.5,-3194 75.5,-3219 308.5,-3219 308.5,-3194 75.5,-3194"/>
+<text text-anchor="start" x="80.5" y="-3203.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="115.5" y="-3203.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
+<polygon fill="none" stroke="black" points="75.5,-3169 75.5,-3194 308.5,-3194 308.5,-3169 75.5,-3169"/>
+<text text-anchor="start" x="80.5" y="-3178.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
+<text text-anchor="start" x="150.5" y="-3178.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
</g>
<!-- log -->
<g id="node30" class="node">
<title>log</title>
-<polygon fill="none" stroke="black" points="86.5,-3670 86.5,-3698 297.5,-3698 297.5,-3670 86.5,-3670"/>
-<text text-anchor="start" x="178" y="-3681.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">log</text>
-<polygon fill="none" stroke="black" points="86.5,-3645 86.5,-3670 297.5,-3670 297.5,-3645 86.5,-3645"/>
-<text text-anchor="start" x="91.5" y="-3654.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="104.5" y="-3654.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="181.5" y="-3654.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="86.5,-3620 86.5,-3645 297.5,-3645 297.5,-3620 86.5,-3620"/>
-<text text-anchor="start" x="91.5" y="-3629.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="137.5" y="-3629.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="86.5,-3595 86.5,-3620 297.5,-3620 297.5,-3595 86.5,-3595"/>
-<text text-anchor="start" x="91.5" y="-3604.8" font-family="Helvetica,sans-Serif" font-size="14.00">dttm</text>
-<text text-anchor="start" x="125.5" y="-3604.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="86.5,-3570 86.5,-3595 297.5,-3595 297.5,-3570 86.5,-3570"/>
-<text text-anchor="start" x="91.5" y="-3579.8" font-family="Helvetica,sans-Serif" font-size="14.00">event</text>
-<text text-anchor="start" x="131.5" y="-3579.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(30)]</text>
-<polygon fill="none" stroke="black" points="86.5,-3545 86.5,-3570 297.5,-3570 297.5,-3545 86.5,-3545"/>
-<text text-anchor="start" x="91.5" y="-3554.8" font-family="Helvetica,sans-Serif" font-size="14.00">execution_date</text>
-<text text-anchor="start" x="196.5" y="-3554.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="86.5,-3520 86.5,-3545 297.5,-3545 297.5,-3520 86.5,-3520"/>
-<text text-anchor="start" x="91.5" y="-3529.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
-<text text-anchor="start" x="128.5" y="-3529.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="86.5,-3495 86.5,-3520 297.5,-3520 297.5,-3495 86.5,-3495"/>
-<text text-anchor="start" x="91.5" y="-3504.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="167.5" y="-3504.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="86.5,-3470 86.5,-3495 297.5,-3495 297.5,-3470 86.5,-3470"/>
-<text text-anchor="start" x="91.5" y="-3479.8" font-family="Helvetica,sans-Serif" font-size="14.00">owner</text>
-<text text-anchor="start" x="134.5" y="-3479.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
-<polygon fill="none" stroke="black" points="86.5,-3445 86.5,-3470 297.5,-3470 297.5,-3445 86.5,-3445"/>
-<text text-anchor="start" x="91.5" y="-3454.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="140.5" y="-3454.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="86.5,-3698 86.5,-3726 297.5,-3726 297.5,-3698 86.5,-3698"/>
+<text text-anchor="start" x="178" y="-3709.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">log</text>
+<polygon fill="none" stroke="black" points="86.5,-3673 86.5,-3698 297.5,-3698 297.5,-3673 86.5,-3673"/>
+<text text-anchor="start" x="91.5" y="-3682.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="104.5" y="-3682.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="181.5" y="-3682.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="86.5,-3648 86.5,-3673 297.5,-3673 297.5,-3648 86.5,-3648"/>
+<text text-anchor="start" x="91.5" y="-3657.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="137.5" y="-3657.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="86.5,-3623 86.5,-3648 297.5,-3648 297.5,-3623 86.5,-3623"/>
+<text text-anchor="start" x="91.5" y="-3632.8" font-family="Helvetica,sans-Serif" font-size="14.00">dttm</text>
+<text text-anchor="start" x="125.5" y="-3632.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="86.5,-3598 86.5,-3623 297.5,-3623 297.5,-3598 86.5,-3598"/>
+<text text-anchor="start" x="91.5" y="-3607.8" font-family="Helvetica,sans-Serif" font-size="14.00">event</text>
+<text text-anchor="start" x="131.5" y="-3607.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(30)]</text>
+<polygon fill="none" stroke="black" points="86.5,-3573 86.5,-3598 297.5,-3598 297.5,-3573 86.5,-3573"/>
+<text text-anchor="start" x="91.5" y="-3582.8" font-family="Helvetica,sans-Serif" font-size="14.00">execution_date</text>
+<text text-anchor="start" x="196.5" y="-3582.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="86.5,-3548 86.5,-3573 297.5,-3573 297.5,-3548 86.5,-3548"/>
+<text text-anchor="start" x="91.5" y="-3557.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
+<text text-anchor="start" x="128.5" y="-3557.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="86.5,-3523 86.5,-3548 297.5,-3548 297.5,-3523 86.5,-3523"/>
+<text text-anchor="start" x="91.5" y="-3532.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="167.5" y="-3532.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="86.5,-3498 86.5,-3523 297.5,-3523 297.5,-3498 86.5,-3498"/>
+<text text-anchor="start" x="91.5" y="-3507.8" font-family="Helvetica,sans-Serif" font-size="14.00">owner</text>
+<text text-anchor="start" x="134.5" y="-3507.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
+<polygon fill="none" stroke="black" points="86.5,-3473 86.5,-3498 297.5,-3498 297.5,-3473 86.5,-3473"/>
+<text text-anchor="start" x="91.5" y="-3482.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="140.5" y="-3482.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
</g>
<!-- trigger -->
<g id="node35" class="node">
@@ -1376,127 +1382,127 @@
<!-- serialized_dag -->
<g id="node36" class="node">
<title>serialized_dag</title>
-<polygon fill="none" stroke="black" points="55.5,-3925 55.5,-3953 327.5,-3953 327.5,-3925 55.5,-3925"/>
-<text text-anchor="start" x="128" y="-3936.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
-<polygon fill="none" stroke="black" points="55.5,-3900 55.5,-3925 327.5,-3925 327.5,-3900 55.5,-3900"/>
-<text text-anchor="start" x="60.5" y="-3909.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="106.5" y="-3909.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="227.5" y="-3909.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3875 55.5,-3900 327.5,-3900 327.5,-3875 55.5,-3875"/>
-<text text-anchor="start" x="60.5" y="-3884.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
-<text text-anchor="start" x="127.5" y="-3884.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
-<text text-anchor="start" x="239.5" y="-3884.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3850 55.5,-3875 327.5,-3875 327.5,-3850 55.5,-3850"/>
-<text text-anchor="start" x="60.5" y="-3859.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
-<text text-anchor="start" x="91.5" y="-3859.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="55.5,-3825 55.5,-3850 327.5,-3850 327.5,-3825 55.5,-3825"/>
-<text text-anchor="start" x="60.5" y="-3834.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
-<text text-anchor="start" x="182.5" y="-3834.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
-<polygon fill="none" stroke="black" points="55.5,-3800 55.5,-3825 327.5,-3825 327.5,-3800 55.5,-3800"/>
-<text text-anchor="start" x="60.5" y="-3809.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
-<text text-anchor="start" x="101.5" y="-3809.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<text text-anchor="start" x="231.5" y="-3809.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3775 55.5,-3800 327.5,-3800 327.5,-3775 55.5,-3775"/>
-<text text-anchor="start" x="60.5" y="-3784.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc_hash</text>
-<text text-anchor="start" x="142.5" y="-3784.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
-<text text-anchor="start" x="206.5" y="-3784.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3750 55.5,-3775 327.5,-3775 327.5,-3750 55.5,-3750"/>
-<text text-anchor="start" x="60.5" y="-3759.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
-<text text-anchor="start" x="150.5" y="-3759.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="246.5" y="-3759.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3725 55.5,-3750 327.5,-3750 327.5,-3725 55.5,-3725"/>
-<text text-anchor="start" x="60.5" y="-3734.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
-<text text-anchor="start" x="179.5" y="-3734.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<polygon fill="none" stroke="black" points="55.5,-3953 55.5,-3981 327.5,-3981 327.5,-3953 55.5,-3953"/>
+<text text-anchor="start" x="128" y="-3964.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
+<polygon fill="none" stroke="black" points="55.5,-3928 55.5,-3953 327.5,-3953 327.5,-3928 55.5,-3928"/>
+<text text-anchor="start" x="60.5" y="-3937.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="106.5" y="-3937.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="227.5" y="-3937.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-3903 55.5,-3928 327.5,-3928 327.5,-3903 55.5,-3903"/>
+<text text-anchor="start" x="60.5" y="-3912.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
+<text text-anchor="start" x="127.5" y="-3912.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<text text-anchor="start" x="239.5" y="-3912.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-3878 55.5,-3903 327.5,-3903 327.5,-3878 55.5,-3878"/>
+<text text-anchor="start" x="60.5" y="-3887.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
+<text text-anchor="start" x="91.5" y="-3887.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="55.5,-3853 55.5,-3878 327.5,-3878 327.5,-3853 55.5,-3853"/>
+<text text-anchor="start" x="60.5" y="-3862.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
+<text text-anchor="start" x="182.5" y="-3862.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
+<polygon fill="none" stroke="black" points="55.5,-3828 55.5,-3853 327.5,-3853 327.5,-3828 55.5,-3828"/>
+<text text-anchor="start" x="60.5" y="-3837.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
+<text text-anchor="start" x="101.5" y="-3837.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="231.5" y="-3837.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-3803 55.5,-3828 327.5,-3828 327.5,-3803 55.5,-3803"/>
+<text text-anchor="start" x="60.5" y="-3812.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc_hash</text>
+<text text-anchor="start" x="142.5" y="-3812.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
+<text text-anchor="start" x="206.5" y="-3812.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-3778 55.5,-3803 327.5,-3803 327.5,-3778 55.5,-3778"/>
+<text text-anchor="start" x="60.5" y="-3787.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
+<text text-anchor="start" x="150.5" y="-3787.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="246.5" y="-3787.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="55.5,-3753 55.5,-3778 327.5,-3778 327.5,-3753 55.5,-3753"/>
+<text text-anchor="start" x="60.5" y="-3762.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
+<text text-anchor="start" x="179.5" y="-3762.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
</g>
<!-- session -->
<g id="node37" class="node">
<title>session</title>
-<polygon fill="none" stroke="black" points="90.5,-4079 90.5,-4107 293.5,-4107 293.5,-4079 90.5,-4079"/>
-<text text-anchor="start" x="158" y="-4090.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">session</text>
-<polygon fill="none" stroke="black" points="90.5,-4054 90.5,-4079 293.5,-4079 293.5,-4054 90.5,-4054"/>
-<text text-anchor="start" x="95.5" y="-4063.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="108.5" y="-4063.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="185.5" y="-4063.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="90.5,-4029 90.5,-4054 293.5,-4054 293.5,-4029 90.5,-4029"/>
-<text text-anchor="start" x="95.5" y="-4038.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
-<text text-anchor="start" x="126.5" y="-4038.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
-<polygon fill="none" stroke="black" points="90.5,-4004 90.5,-4029 293.5,-4029 293.5,-4004 90.5,-4004"/>
-<text text-anchor="start" x="95.5" y="-4013.8" font-family="Helvetica,sans-Serif" font-size="14.00">expiry</text>
-<text text-anchor="start" x="139.5" y="-4013.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DATETIME]</text>
-<polygon fill="none" stroke="black" points="90.5,-3979 90.5,-4004 293.5,-4004 293.5,-3979 90.5,-3979"/>
-<text text-anchor="start" x="95.5" y="-3988.8" font-family="Helvetica,sans-Serif" font-size="14.00">session_id</text>
-<text text-anchor="start" x="167.5" y="-3988.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(255)]</text>
+<polygon fill="none" stroke="black" points="90.5,-4107 90.5,-4135 293.5,-4135 293.5,-4107 90.5,-4107"/>
+<text text-anchor="start" x="158" y="-4118.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">session</text>
+<polygon fill="none" stroke="black" points="90.5,-4082 90.5,-4107 293.5,-4107 293.5,-4082 90.5,-4082"/>
+<text text-anchor="start" x="95.5" y="-4091.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="108.5" y="-4091.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="185.5" y="-4091.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="90.5,-4057 90.5,-4082 293.5,-4082 293.5,-4057 90.5,-4057"/>
+<text text-anchor="start" x="95.5" y="-4066.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
+<text text-anchor="start" x="126.5" y="-4066.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BLOB]</text>
+<polygon fill="none" stroke="black" points="90.5,-4032 90.5,-4057 293.5,-4057 293.5,-4032 90.5,-4032"/>
+<text text-anchor="start" x="95.5" y="-4041.8" font-family="Helvetica,sans-Serif" font-size="14.00">expiry</text>
+<text text-anchor="start" x="139.5" y="-4041.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DATETIME]</text>
+<polygon fill="none" stroke="black" points="90.5,-4007 90.5,-4032 293.5,-4032 293.5,-4007 90.5,-4007"/>
+<text text-anchor="start" x="95.5" y="-4016.8" font-family="Helvetica,sans-Serif" font-size="14.00">session_id</text>
+<text text-anchor="start" x="167.5" y="-4016.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(255)]</text>
</g>
<!-- sla_miss -->
<g id="node38" class="node">
<title>sla_miss</title>
-<polygon fill="none" stroke="black" points="48.5,-4308 48.5,-4336 335.5,-4336 335.5,-4308 48.5,-4308"/>
-<text text-anchor="start" x="154" y="-4319.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">sla_miss</text>
-<polygon fill="none" stroke="black" points="48.5,-4283 48.5,-4308 335.5,-4308 335.5,-4283 48.5,-4283"/>
-<text text-anchor="start" x="53.5" y="-4292.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="99.5" y="-4292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="220.5" y="-4292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="48.5,-4258 48.5,-4283 335.5,-4283 335.5,-4258 48.5,-4258"/>
-<text text-anchor="start" x="53.5" y="-4267.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">execution_date</text>
-<text text-anchor="start" x="158.5" y="-4267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="254.5" y="-4267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="48.5,-4233 48.5,-4258 335.5,-4258 335.5,-4233 48.5,-4233"/>
-<text text-anchor="start" x="53.5" y="-4242.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="102.5" y="-4242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="223.5" y="-4242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="48.5,-4208 48.5,-4233 335.5,-4233 335.5,-4208 48.5,-4208"/>
-<text text-anchor="start" x="53.5" y="-4217.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="131.5" y="-4217.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="48.5,-4183 48.5,-4208 335.5,-4208 335.5,-4183 48.5,-4183"/>
-<text text-anchor="start" x="53.5" y="-4192.8" font-family="Helvetica,sans-Serif" font-size="14.00">email_sent</text>
-<text text-anchor="start" x="128.5" y="-4192.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="48.5,-4158 48.5,-4183 335.5,-4183 335.5,-4158 48.5,-4158"/>
-<text text-anchor="start" x="53.5" y="-4167.8" font-family="Helvetica,sans-Serif" font-size="14.00">notification_sent</text>
-<text text-anchor="start" x="168.5" y="-4167.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="48.5,-4133 48.5,-4158 335.5,-4158 335.5,-4133 48.5,-4133"/>
-<text text-anchor="start" x="53.5" y="-4142.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="128.5" y="-4142.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="48.5,-4336 48.5,-4364 335.5,-4364 335.5,-4336 48.5,-4336"/>
+<text text-anchor="start" x="154" y="-4347.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">sla_miss</text>
+<polygon fill="none" stroke="black" points="48.5,-4311 48.5,-4336 335.5,-4336 335.5,-4311 48.5,-4311"/>
+<text text-anchor="start" x="53.5" y="-4320.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="99.5" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="220.5" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="48.5,-4286 48.5,-4311 335.5,-4311 335.5,-4286 48.5,-4286"/>
+<text text-anchor="start" x="53.5" y="-4295.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">execution_date</text>
+<text text-anchor="start" x="158.5" y="-4295.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="254.5" y="-4295.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="48.5,-4261 48.5,-4286 335.5,-4286 335.5,-4261 48.5,-4261"/>
+<text text-anchor="start" x="53.5" y="-4270.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="102.5" y="-4270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="223.5" y="-4270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="48.5,-4236 48.5,-4261 335.5,-4261 335.5,-4236 48.5,-4236"/>
+<text text-anchor="start" x="53.5" y="-4245.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="131.5" y="-4245.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="48.5,-4211 48.5,-4236 335.5,-4236 335.5,-4211 48.5,-4211"/>
+<text text-anchor="start" x="53.5" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00">email_sent</text>
+<text text-anchor="start" x="128.5" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<polygon fill="none" stroke="black" points="48.5,-4186 48.5,-4211 335.5,-4211 335.5,-4186 48.5,-4186"/>
+<text text-anchor="start" x="53.5" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00">notification_sent</text>
+<text text-anchor="start" x="168.5" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<polygon fill="none" stroke="black" points="48.5,-4161 48.5,-4186 335.5,-4186 335.5,-4161 48.5,-4161"/>
+<text text-anchor="start" x="53.5" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="128.5" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- slot_pool -->
<g id="node39" class="node">
<title>slot_pool</title>
-<polygon fill="none" stroke="black" points="103.5,-4463 103.5,-4491 279.5,-4491 279.5,-4463 103.5,-4463"/>
-<text text-anchor="start" x="150.5" y="-4474.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">slot_pool</text>
-<polygon fill="none" stroke="black" points="103.5,-4438 103.5,-4463 279.5,-4463 279.5,-4438 103.5,-4438"/>
-<text text-anchor="start" x="108.5" y="-4447.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="121.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="198.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="103.5,-4413 103.5,-4438 279.5,-4438 279.5,-4413 103.5,-4413"/>
-<text text-anchor="start" x="108.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="186.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="103.5,-4388 103.5,-4413 279.5,-4413 279.5,-4388 103.5,-4388"/>
-<text text-anchor="start" x="108.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
-<text text-anchor="start" x="138.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<polygon fill="none" stroke="black" points="103.5,-4363 103.5,-4388 279.5,-4388 279.5,-4363 103.5,-4363"/>
-<text text-anchor="start" x="108.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00">slots</text>
-<text text-anchor="start" x="141.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="103.5,-4491 103.5,-4519 279.5,-4519 279.5,-4491 103.5,-4491"/>
+<text text-anchor="start" x="150.5" y="-4502.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">slot_pool</text>
+<polygon fill="none" stroke="black" points="103.5,-4466 103.5,-4491 279.5,-4491 279.5,-4466 103.5,-4466"/>
+<text text-anchor="start" x="108.5" y="-4475.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="121.5" y="-4475.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="198.5" y="-4475.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="103.5,-4441 103.5,-4466 279.5,-4466 279.5,-4441 103.5,-4441"/>
+<text text-anchor="start" x="108.5" y="-4450.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="186.5" y="-4450.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="103.5,-4416 103.5,-4441 279.5,-4441 279.5,-4416 103.5,-4416"/>
+<text text-anchor="start" x="108.5" y="-4425.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
+<text text-anchor="start" x="138.5" y="-4425.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<polygon fill="none" stroke="black" points="103.5,-4391 103.5,-4416 279.5,-4416 279.5,-4391 103.5,-4391"/>
+<text text-anchor="start" x="108.5" y="-4400.8" font-family="Helvetica,sans-Serif" font-size="14.00">slots</text>
+<text text-anchor="start" x="141.5" y="-4400.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- variable -->
<g id="node40" class="node">
<title>variable</title>
-<polygon fill="none" stroke="black" points="100.5,-4642 100.5,-4670 283.5,-4670 283.5,-4642 100.5,-4642"/>
-<text text-anchor="start" x="155.5" y="-4653.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">variable</text>
-<polygon fill="none" stroke="black" points="100.5,-4617 100.5,-4642 283.5,-4642 283.5,-4617 100.5,-4617"/>
-<text text-anchor="start" x="105.5" y="-4626.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="118.5" y="-4626.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="195.5" y="-4626.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="100.5,-4592 100.5,-4617 283.5,-4617 283.5,-4592 100.5,-4592"/>
-<text text-anchor="start" x="105.5" y="-4601.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="183.5" y="-4601.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="100.5,-4567 100.5,-4592 283.5,-4592 283.5,-4567 100.5,-4567"/>
-<text text-anchor="start" x="105.5" y="-4576.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_encrypted</text>
-<text text-anchor="start" x="194.5" y="-4576.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="100.5,-4542 100.5,-4567 283.5,-4567 283.5,-4542 100.5,-4542"/>
-<text text-anchor="start" x="105.5" y="-4551.8" font-family="Helvetica,sans-Serif" font-size="14.00">key</text>
-<text text-anchor="start" x="130.5" y="-4551.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="100.5,-4517 100.5,-4542 283.5,-4542 283.5,-4517 100.5,-4517"/>
-<text text-anchor="start" x="105.5" y="-4526.8" font-family="Helvetica,sans-Serif" font-size="14.00">val</text>
-<text text-anchor="start" x="126.5" y="-4526.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="100.5,-4670 100.5,-4698 283.5,-4698 283.5,-4670 100.5,-4670"/>
+<text text-anchor="start" x="155.5" y="-4681.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">variable</text>
+<polygon fill="none" stroke="black" points="100.5,-4645 100.5,-4670 283.5,-4670 283.5,-4645 100.5,-4645"/>
+<text text-anchor="start" x="105.5" y="-4654.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="118.5" y="-4654.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="195.5" y="-4654.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="100.5,-4620 100.5,-4645 283.5,-4645 283.5,-4620 100.5,-4620"/>
+<text text-anchor="start" x="105.5" y="-4629.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="183.5" y="-4629.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="100.5,-4595 100.5,-4620 283.5,-4620 283.5,-4595 100.5,-4595"/>
+<text text-anchor="start" x="105.5" y="-4604.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_encrypted</text>
+<text text-anchor="start" x="194.5" y="-4604.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<polygon fill="none" stroke="black" points="100.5,-4570 100.5,-4595 283.5,-4595 283.5,-4570 100.5,-4570"/>
+<text text-anchor="start" x="105.5" y="-4579.8" font-family="Helvetica,sans-Serif" font-size="14.00">key</text>
+<text text-anchor="start" x="130.5" y="-4579.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="100.5,-4545 100.5,-4570 283.5,-4570 283.5,-4545 100.5,-4545"/>
+<text text-anchor="start" x="105.5" y="-4554.8" font-family="Helvetica,sans-Serif" font-size="14.00">val</text>
+<text text-anchor="start" x="126.5" y="-4554.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
</g>
</g>
</svg>
diff --git a/docs/apache-airflow/migrations-ref.rst b/docs/apache-airflow/migrations-ref.rst
index fa1606946f..3b92588ba0 100644
--- a/docs/apache-airflow/migrations-ref.rst
+++ b/docs/apache-airflow/migrations-ref.rst
@@ -39,7 +39,9 @@ Here's the list of all the Database Migrations that are executed via when you ru
+---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
| Revision ID | Revises ID | Airflow Version | Description |
+=================================+===================+===================+==============================================================+
-| ``ecb43d2a1842`` (head) | ``1486deb605b4`` | ``2.4.0`` | Add processor_subdir column to DagModel, SerializedDagModel |
+| ``ee8d93fcc81e`` (head) | ``ecb43d2a1842`` | ``2.5.0`` | Add updated_at column to DagRun and TaskInstance |
++---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
+| ``ecb43d2a1842`` | ``1486deb605b4`` | ``2.4.0`` | Add processor_subdir column to DagModel, SerializedDagModel |
| | | | and CallbackRequest tables. |
+---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
| ``1486deb605b4`` | ``f4ff391becb5`` | ``2.4.0`` | add dag_owner_attributes table |
diff --git a/tests/models/test_taskinstance.py b/tests/models/test_taskinstance.py
index a9b5dd69d2..0589e96d32 100644
--- a/tests/models/test_taskinstance.py
+++ b/tests/models/test_taskinstance.py
@@ -2647,6 +2647,7 @@ class TestTaskInstance:
"trigger_id": None,
"next_kwargs": None,
"next_method": None,
+ "updated_at": None,
}
# Make sure we aren't missing any new value in our expected_values list.
expected_keys = {f"task_instance.{key.lstrip('_')}" for key in expected_values}