You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2023/12/05 10:33:58 UTC
(airflow) 13/34: Add processor_subdir to import_error table to handle multiple dag processors (#35956)
This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch v2-8-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 7b03a11dc958d6252b773cbdd5686c3c55ce9fa1
Author: Karthikeyan Singaravelan <ti...@gmail.com>
AuthorDate: Thu Nov 30 18:59:52 2023 +0530
Add processor_subdir to import_error table to handle multiple dag processors (#35956)
* Add processor_subdir to import_error table to handle multiple dag processors.
* Fix migration table name.
(cherry picked from commit 1a3eeab76cdb6d0584452e3065aee103ad9ab641)
---
airflow/dag_processing/manager.py | 13 +-
airflow/dag_processing/processor.py | 14 +-
...0133_2_8_0_add_processor_subdir_import_error.py | 54 +
airflow/models/errors.py | 1 +
airflow/utils/db.py | 2 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 1528 ++++++++++----------
docs/apache-airflow/migrations-ref.rst | 4 +-
tests/dag_processing/test_job_runner.py | 62 +
9 files changed, 911 insertions(+), 769 deletions(-)
diff --git a/airflow/dag_processing/manager.py b/airflow/dag_processing/manager.py
index 909425e569..b4b4ed65fe 100644
--- a/airflow/dag_processing/manager.py
+++ b/airflow/dag_processing/manager.py
@@ -743,7 +743,9 @@ class DagFileProcessorManager(LoggingMixin):
try:
self.log.debug("Removing old import errors")
- DagFileProcessorManager.clear_nonexistent_import_errors(file_paths=self._file_paths)
+ DagFileProcessorManager.clear_nonexistent_import_errors(
+ file_paths=self._file_paths, processor_subdir=self.get_dag_directory()
+ )
except Exception:
self.log.exception("Error removing old import errors")
@@ -793,7 +795,9 @@ class DagFileProcessorManager(LoggingMixin):
@staticmethod
@internal_api_call
@provide_session
- def clear_nonexistent_import_errors(file_paths: list[str] | None, session=NEW_SESSION):
+ def clear_nonexistent_import_errors(
+ file_paths: list[str] | None, processor_subdir: str | None, session=NEW_SESSION
+ ):
"""
Clear import errors for files that no longer exist.
@@ -803,7 +807,10 @@ class DagFileProcessorManager(LoggingMixin):
query = delete(errors.ImportError)
if file_paths:
- query = query.where(~errors.ImportError.filename.in_(file_paths))
+ query = query.where(
+ ~errors.ImportError.filename.in_(file_paths),
+ errors.ImportError.processor_subdir == processor_subdir,
+ )
session.execute(query.execution_options(synchronize_session="fetch"))
session.commit()
diff --git a/airflow/dag_processing/processor.py b/airflow/dag_processing/processor.py
index 5209e6bfd2..ce4c51552b 100644
--- a/airflow/dag_processing/processor.py
+++ b/airflow/dag_processing/processor.py
@@ -592,7 +592,10 @@ class DagFileProcessor(LoggingMixin):
@internal_api_call
@provide_session
def update_import_errors(
- file_last_changed: dict[str, datetime], import_errors: dict[str, str], session: Session = NEW_SESSION
+ file_last_changed: dict[str, datetime],
+ import_errors: dict[str, str],
+ processor_subdir: str | None,
+ session: Session = NEW_SESSION,
) -> None:
"""
Update any import errors to be displayed in the UI.
@@ -627,7 +630,12 @@ class DagFileProcessor(LoggingMixin):
)
else:
session.add(
- errors.ImportError(filename=filename, timestamp=timezone.utcnow(), stacktrace=stacktrace)
+ errors.ImportError(
+ filename=filename,
+ timestamp=timezone.utcnow(),
+ stacktrace=stacktrace,
+ processor_subdir=processor_subdir,
+ )
)
(
session.query(DagModel)
@@ -835,6 +843,7 @@ class DagFileProcessor(LoggingMixin):
DagFileProcessor.update_import_errors(
file_last_changed=dagbag.file_last_changed,
import_errors=dagbag.import_errors,
+ processor_subdir=self._dag_directory,
session=session,
)
if callback_requests:
@@ -860,6 +869,7 @@ class DagFileProcessor(LoggingMixin):
DagFileProcessor.update_import_errors(
file_last_changed=dagbag.file_last_changed,
import_errors=dagbag.import_errors,
+ processor_subdir=self._dag_directory,
session=session,
)
except Exception:
diff --git a/airflow/migrations/versions/0133_2_8_0_add_processor_subdir_import_error.py b/airflow/migrations/versions/0133_2_8_0_add_processor_subdir_import_error.py
new file mode 100644
index 0000000000..9509047efa
--- /dev/null
+++ b/airflow/migrations/versions/0133_2_8_0_add_processor_subdir_import_error.py
@@ -0,0 +1,54 @@
+#
+# 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 processor_subdir to ImportError.
+
+Revision ID: 10b52ebd31f7
+Revises: 624ecf3b6a5e
+Create Date: 2023-11-29 16:54:48.101834
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+
+# revision identifiers, used by Alembic.
+revision = "10b52ebd31f7"
+down_revision = "624ecf3b6a5e"
+branch_labels = None
+depends_on = None
+airflow_version = "2.8.0"
+
+
+def upgrade():
+ """Apply Add processor_subdir to ImportError."""
+ conn = op.get_bind()
+
+ with op.batch_alter_table("import_error") as batch_op:
+ if conn.dialect.name == "mysql":
+ batch_op.add_column(sa.Column("processor_subdir", sa.Text(length=2000), nullable=True))
+ else:
+ batch_op.add_column(sa.Column("processor_subdir", sa.String(length=2000), nullable=True))
+
+
+def downgrade():
+ """Unapply Add processor_subdir to ImportError."""
+ conn = op.get_bind()
+ with op.batch_alter_table("import_error", schema=None) as batch_op:
+ batch_op.drop_column("processor_subdir")
diff --git a/airflow/models/errors.py b/airflow/models/errors.py
index 9d2da0917d..ed76c6c355 100644
--- a/airflow/models/errors.py
+++ b/airflow/models/errors.py
@@ -31,3 +31,4 @@ class ImportError(Base):
timestamp = Column(UtcDateTime)
filename = Column(String(1024))
stacktrace = Column(Text)
+ processor_subdir = Column(String(2000), nullable=True)
diff --git a/airflow/utils/db.py b/airflow/utils/db.py
index b9509cf8d1..25a889f639 100644
--- a/airflow/utils/db.py
+++ b/airflow/utils/db.py
@@ -88,7 +88,7 @@ _REVISION_HEADS_MAP = {
"2.6.0": "98ae134e6fff",
"2.6.2": "c804e5c76e3e",
"2.7.0": "405de8318b3a",
- "2.8.0": "624ecf3b6a5e",
+ "2.8.0": "10b52ebd31f7",
}
diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256
index b2d9dbf5a2..93eff299cb 100644
--- a/docs/apache-airflow/img/airflow_erd.sha256
+++ b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-4739d87664d779f93e39b09ca6e5e662d72f1fa88857d8b6e44d2f2557656753
\ No newline at end of file
+5d80302f775a966cffc5ed6c452c56a9e181afce92dc4ccf9b29b21171091f38
\ 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 91b4231b3e..317dc89041 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="1559pt" height="5142pt"
- viewBox="0.00 0.00 1559.00 5141.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 5137.5)">
+<svg width="1565pt" height="5167pt"
+ viewBox="0.00 0.00 1565.00 5166.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 5162.5)">
<title>%3</title>
-<polygon fill="white" stroke="transparent" points="-4,4 -4,-5137.5 1555,-5137.5 1555,4 -4,4"/>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-5162.5 1561,-5162.5 1561,4 -4,4"/>
<!-- job -->
<g id="node1" class="node">
<title>job</title>
@@ -217,99 +217,99 @@
<!-- ab_user_role -->
<g id="node7" class="node">
<title>ab_user_role</title>
-<polygon fill="none" stroke="black" points="918.5,-2028 918.5,-2056 1094.5,-2056 1094.5,-2028 918.5,-2028"/>
-<text text-anchor="start" x="949.5" y="-2039.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_user_role</text>
-<polygon fill="none" stroke="black" points="918.5,-2003 918.5,-2028 1094.5,-2028 1094.5,-2003 918.5,-2003"/>
-<text text-anchor="start" x="923.5" y="-2012.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="936.5" y="-2012.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1013.5" y="-2012.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="918.5,-1978 918.5,-2003 1094.5,-2003 1094.5,-1978 918.5,-1978"/>
-<text text-anchor="start" x="923.5" y="-1987.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
-<text text-anchor="start" x="969.5" y="-1987.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="918.5,-1953 918.5,-1978 1094.5,-1978 1094.5,-1953 918.5,-1953"/>
-<text text-anchor="start" x="923.5" y="-1962.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="974.5" y="-1962.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="921.5,-2028 921.5,-2056 1097.5,-2056 1097.5,-2028 921.5,-2028"/>
+<text text-anchor="start" x="952.5" y="-2039.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_user_role</text>
+<polygon fill="none" stroke="black" points="921.5,-2003 921.5,-2028 1097.5,-2028 1097.5,-2003 921.5,-2003"/>
+<text text-anchor="start" x="926.5" y="-2012.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="939.5" y="-2012.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1016.5" y="-2012.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="921.5,-1978 921.5,-2003 1097.5,-2003 1097.5,-1978 921.5,-1978"/>
+<text text-anchor="start" x="926.5" y="-1987.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
+<text text-anchor="start" x="972.5" y="-1987.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="921.5,-1953 921.5,-1978 1097.5,-1978 1097.5,-1953 921.5,-1953"/>
+<text text-anchor="start" x="926.5" y="-1962.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="977.5" y="-1962.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_user--ab_user_role -->
<g id="edge3" class="edge">
<title>ab_user--ab_user_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.53,-1930.45C812.73,-1945.61 866.21,-1962.09 910.35,-1975.69"/>
-<text text-anchor="start" x="879.35" y="-1964.49" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="763.53" y="-1919.25" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.55,-1930.11C813.66,-1945.43 868.3,-1962.14 913.23,-1975.87"/>
+<text text-anchor="start" x="882.23" y="-1964.67" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="763.55" y="-1918.91" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- dag_run_note -->
<g id="node8" class="node">
<title>dag_run_note</title>
-<polygon fill="none" stroke="black" points="876.5,-1433 876.5,-1461 1137.5,-1461 1137.5,-1433 876.5,-1433"/>
-<text text-anchor="start" x="946.5" y="-1444.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run_note</text>
-<polygon fill="none" stroke="black" points="876.5,-1408 876.5,-1433 1137.5,-1433 1137.5,-1408 876.5,-1408"/>
-<text text-anchor="start" x="881.5" y="-1417.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="958.5" y="-1417.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1035.5" y="-1417.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="876.5,-1383 876.5,-1408 1137.5,-1408 1137.5,-1383 876.5,-1383"/>
-<text text-anchor="start" x="881.5" y="-1392.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
-<text text-anchor="start" x="934.5" y="-1392.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="876.5,-1358 876.5,-1383 1137.5,-1383 1137.5,-1358 876.5,-1358"/>
-<text text-anchor="start" x="881.5" y="-1367.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="954.5" y="-1367.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1050.5" y="-1367.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="876.5,-1333 876.5,-1358 1137.5,-1358 1137.5,-1333 876.5,-1333"/>
-<text text-anchor="start" x="881.5" y="-1342.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="960.5" y="-1342.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1056.5" y="-1342.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="876.5,-1308 876.5,-1333 1137.5,-1333 1137.5,-1308 876.5,-1308"/>
-<text text-anchor="start" x="881.5" y="-1317.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="932.5" y="-1317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="879.5,-1436 879.5,-1464 1140.5,-1464 1140.5,-1436 879.5,-1436"/>
+<text text-anchor="start" x="949.5" y="-1447.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run_note</text>
+<polygon fill="none" stroke="black" points="879.5,-1411 879.5,-1436 1140.5,-1436 1140.5,-1411 879.5,-1411"/>
+<text text-anchor="start" x="884.5" y="-1420.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="961.5" y="-1420.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1038.5" y="-1420.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="879.5,-1386 879.5,-1411 1140.5,-1411 1140.5,-1386 879.5,-1386"/>
+<text text-anchor="start" x="884.5" y="-1395.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
+<text text-anchor="start" x="937.5" y="-1395.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="879.5,-1361 879.5,-1386 1140.5,-1386 1140.5,-1361 879.5,-1361"/>
+<text text-anchor="start" x="884.5" y="-1370.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="957.5" y="-1370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1053.5" y="-1370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="879.5,-1336 879.5,-1361 1140.5,-1361 1140.5,-1336 879.5,-1336"/>
+<text text-anchor="start" x="884.5" y="-1345.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="963.5" y="-1345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1059.5" y="-1345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="879.5,-1311 879.5,-1336 1140.5,-1336 1140.5,-1311 879.5,-1311"/>
+<text text-anchor="start" x="884.5" y="-1320.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="935.5" y="-1320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_user--dag_run_note -->
<g id="edge4" class="edge">
<title>ab_user--dag_run_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.57,-1700.78C767.19,-1694.86 770.68,-1688.92 774,-1683 819.26,-1602.28 789.07,-1560.17 847,-1488 853.27,-1480.19 860.29,-1472.79 867.8,-1465.79"/>
-<text text-anchor="start" x="836.8" y="-1454.59" font-family="Times,serif" font-size="14.00">0..N</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.57,-1700.78C767.19,-1694.86 770.68,-1688.92 774,-1683 819.26,-1602.28 788.29,-1559.53 847,-1488 854.11,-1479.33 862.19,-1471.2 870.84,-1463.62"/>
+<text text-anchor="start" x="839.84" y="-1452.42" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="763.57" y="-1689.58" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- task_instance_note -->
<g id="node9" class="node">
<title>task_instance_note</title>
-<polygon fill="none" stroke="black" points="1265,-1606 1265,-1634 1526,-1634 1526,-1606 1265,-1606"/>
-<text text-anchor="start" x="1309.5" y="-1617.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_note</text>
-<polygon fill="none" stroke="black" points="1265,-1581 1265,-1606 1526,-1606 1526,-1581 1265,-1581"/>
-<text text-anchor="start" x="1270" y="-1590.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1316" y="-1590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1437" y="-1590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1556 1265,-1581 1526,-1581 1526,-1556 1265,-1556"/>
-<text text-anchor="start" x="1270" y="-1565.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1346" y="-1565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1423" y="-1565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1531 1265,-1556 1526,-1556 1526,-1531 1265,-1531"/>
-<text text-anchor="start" x="1270" y="-1540.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1314" y="-1540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1435" y="-1540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1506 1265,-1531 1526,-1531 1526,-1506 1265,-1506"/>
-<text text-anchor="start" x="1270" y="-1515.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1319" y="-1515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1440" y="-1515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1481 1265,-1506 1526,-1506 1526,-1481 1265,-1481"/>
-<text text-anchor="start" x="1270" y="-1490.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
-<text text-anchor="start" x="1323" y="-1490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1265,-1456 1265,-1481 1526,-1481 1526,-1456 1265,-1456"/>
-<text text-anchor="start" x="1270" y="-1465.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="1343" y="-1465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1439" y="-1465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1431 1265,-1456 1526,-1456 1526,-1431 1265,-1431"/>
-<text text-anchor="start" x="1270" y="-1440.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1349" y="-1440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1445" y="-1440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1265,-1406 1265,-1431 1526,-1431 1526,-1406 1265,-1406"/>
-<text text-anchor="start" x="1270" y="-1415.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="1321" y="-1415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1271,-1615 1271,-1643 1532,-1643 1532,-1615 1271,-1615"/>
+<text text-anchor="start" x="1315.5" y="-1626.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_note</text>
+<polygon fill="none" stroke="black" points="1271,-1590 1271,-1615 1532,-1615 1532,-1590 1271,-1590"/>
+<text text-anchor="start" x="1276" y="-1599.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1322" y="-1599.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1443" y="-1599.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1565 1271,-1590 1532,-1590 1532,-1565 1271,-1565"/>
+<text text-anchor="start" x="1276" y="-1574.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1352" y="-1574.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1429" y="-1574.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1540 1271,-1565 1532,-1565 1532,-1540 1271,-1540"/>
+<text text-anchor="start" x="1276" y="-1549.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1320" y="-1549.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1441" y="-1549.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1515 1271,-1540 1532,-1540 1532,-1515 1271,-1515"/>
+<text text-anchor="start" x="1276" y="-1524.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1325" y="-1524.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1446" y="-1524.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1490 1271,-1515 1532,-1515 1532,-1490 1271,-1490"/>
+<text text-anchor="start" x="1276" y="-1499.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
+<text text-anchor="start" x="1329" y="-1499.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1271,-1465 1271,-1490 1532,-1490 1532,-1465 1271,-1465"/>
+<text text-anchor="start" x="1276" y="-1474.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="1349" y="-1474.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1445" y="-1474.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1440 1271,-1465 1532,-1465 1532,-1440 1271,-1440"/>
+<text text-anchor="start" x="1276" y="-1449.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1355" y="-1449.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1451" y="-1449.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1271,-1415 1271,-1440 1532,-1440 1532,-1415 1271,-1415"/>
+<text text-anchor="start" x="1276" y="-1424.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="1327" y="-1424.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_user--task_instance_note -->
<g id="edge5" class="edge">
<title>ab_user--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.71,-1815.7C905.51,-1749.18 1117.99,-1649.49 1256.33,-1584.59"/>
-<text text-anchor="start" x="1225.33" y="-1573.39" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="763.71" y="-1804.5" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M763.93,-1817.83C907.14,-1752.8 1122.56,-1654.98 1262.23,-1591.56"/>
+<text text-anchor="start" x="1231.23" y="-1580.36" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="763.93" y="-1806.63" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- ab_register_user -->
<g id="node10" class="node">
@@ -423,405 +423,408 @@
<!-- import_error -->
<g id="node13" class="node">
<title>import_error</title>
-<polygon fill="none" stroke="black" points="91.5,-3321 91.5,-3349 292.5,-3349 292.5,-3321 91.5,-3321"/>
-<text text-anchor="start" x="134.5" y="-3332.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">import_error</text>
-<polygon fill="none" stroke="black" points="91.5,-3296 91.5,-3321 292.5,-3321 292.5,-3296 91.5,-3296"/>
-<text text-anchor="start" x="96.5" y="-3305.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="109.5" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="186.5" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="91.5,-3271 91.5,-3296 292.5,-3296 292.5,-3271 91.5,-3271"/>
-<text text-anchor="start" x="96.5" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
-<text text-anchor="start" x="157.5" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1024)]</text>
-<polygon fill="none" stroke="black" points="91.5,-3246 91.5,-3271 292.5,-3271 292.5,-3246 91.5,-3246"/>
-<text text-anchor="start" x="96.5" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00">stacktrace</text>
-<text text-anchor="start" x="169.5" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<polygon fill="none" stroke="black" points="91.5,-3221 91.5,-3246 292.5,-3246 292.5,-3221 91.5,-3221"/>
-<text text-anchor="start" x="96.5" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="171.5" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="62.5,-3346 62.5,-3374 321.5,-3374 321.5,-3346 62.5,-3346"/>
+<text text-anchor="start" x="134.5" y="-3357.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">import_error</text>
+<polygon fill="none" stroke="black" points="62.5,-3321 62.5,-3346 321.5,-3346 321.5,-3321 62.5,-3321"/>
+<text text-anchor="start" x="67.5" y="-3330.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="80.5" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="157.5" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="62.5,-3296 62.5,-3321 321.5,-3321 321.5,-3296 62.5,-3296"/>
+<text text-anchor="start" x="67.5" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00">filename</text>
+<text text-anchor="start" x="128.5" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1024)]</text>
+<polygon fill="none" stroke="black" points="62.5,-3271 62.5,-3296 321.5,-3296 321.5,-3271 62.5,-3271"/>
+<text text-anchor="start" x="67.5" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
+<text text-anchor="start" x="186.5" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<polygon fill="none" stroke="black" points="62.5,-3246 62.5,-3271 321.5,-3271 321.5,-3246 62.5,-3246"/>
+<text text-anchor="start" x="67.5" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00">stacktrace</text>
+<text text-anchor="start" x="140.5" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<polygon fill="none" stroke="black" points="62.5,-3221 62.5,-3246 321.5,-3246 321.5,-3221 62.5,-3221"/>
+<text text-anchor="start" x="67.5" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="142.5" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- sla_miss -->
<g id="node14" class="node">
<title>sla_miss</title>
-<polygon fill="none" stroke="black" points="48.5,-3550 48.5,-3578 335.5,-3578 335.5,-3550 48.5,-3550"/>
-<text text-anchor="start" x="154" y="-3561.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">sla_miss</text>
+<polygon fill="none" stroke="black" points="48.5,-3575 48.5,-3603 335.5,-3603 335.5,-3575 48.5,-3575"/>
+<text text-anchor="start" x="154" y="-3586.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">sla_miss</text>
+<polygon fill="none" stroke="black" points="48.5,-3550 48.5,-3575 335.5,-3575 335.5,-3550 48.5,-3550"/>
+<text text-anchor="start" x="53.5" y="-3559.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="99.5" y="-3559.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="220.5" y="-3559.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="48.5,-3525 48.5,-3550 335.5,-3550 335.5,-3525 48.5,-3525"/>
-<text text-anchor="start" x="53.5" y="-3534.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="99.5" y="-3534.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="220.5" y="-3534.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="53.5" y="-3534.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">execution_date</text>
+<text text-anchor="start" x="158.5" y="-3534.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="254.5" y="-3534.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="48.5,-3500 48.5,-3525 335.5,-3525 335.5,-3500 48.5,-3500"/>
-<text text-anchor="start" x="53.5" y="-3509.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">execution_date</text>
-<text text-anchor="start" x="158.5" y="-3509.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="254.5" y="-3509.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="53.5" y="-3509.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="102.5" y="-3509.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="223.5" y="-3509.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="48.5,-3475 48.5,-3500 335.5,-3500 335.5,-3475 48.5,-3475"/>
-<text text-anchor="start" x="53.5" y="-3484.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="102.5" y="-3484.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="223.5" y="-3484.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="53.5" y="-3484.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="131.5" y="-3484.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
<polygon fill="none" stroke="black" points="48.5,-3450 48.5,-3475 335.5,-3475 335.5,-3450 48.5,-3450"/>
-<text text-anchor="start" x="53.5" y="-3459.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="131.5" y="-3459.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="53.5" y="-3459.8" font-family="Helvetica,sans-Serif" font-size="14.00">email_sent</text>
+<text text-anchor="start" x="128.5" y="-3459.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="48.5,-3425 48.5,-3450 335.5,-3450 335.5,-3425 48.5,-3425"/>
-<text text-anchor="start" x="53.5" y="-3434.8" font-family="Helvetica,sans-Serif" font-size="14.00">email_sent</text>
-<text text-anchor="start" x="128.5" y="-3434.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="53.5" y="-3434.8" font-family="Helvetica,sans-Serif" font-size="14.00">notification_sent</text>
+<text text-anchor="start" x="168.5" y="-3434.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="48.5,-3400 48.5,-3425 335.5,-3425 335.5,-3400 48.5,-3400"/>
-<text text-anchor="start" x="53.5" y="-3409.8" font-family="Helvetica,sans-Serif" font-size="14.00">notification_sent</text>
-<text text-anchor="start" x="168.5" y="-3409.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="48.5,-3375 48.5,-3400 335.5,-3400 335.5,-3375 48.5,-3375"/>
-<text text-anchor="start" x="53.5" y="-3384.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="128.5" y="-3384.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="53.5" y="-3409.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="128.5" y="-3409.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- variable -->
<g id="node15" class="node">
<title>variable</title>
-<polygon fill="none" stroke="black" points="100.5,-3729 100.5,-3757 283.5,-3757 283.5,-3729 100.5,-3729"/>
-<text text-anchor="start" x="155.5" y="-3740.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">variable</text>
+<polygon fill="none" stroke="black" points="100.5,-3754 100.5,-3782 283.5,-3782 283.5,-3754 100.5,-3754"/>
+<text text-anchor="start" x="155.5" y="-3765.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">variable</text>
+<polygon fill="none" stroke="black" points="100.5,-3729 100.5,-3754 283.5,-3754 283.5,-3729 100.5,-3729"/>
+<text text-anchor="start" x="105.5" y="-3738.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="118.5" y="-3738.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="195.5" y="-3738.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="100.5,-3704 100.5,-3729 283.5,-3729 283.5,-3704 100.5,-3704"/>
-<text text-anchor="start" x="105.5" y="-3713.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="118.5" y="-3713.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="195.5" y="-3713.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="105.5" y="-3713.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="183.5" y="-3713.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
<polygon fill="none" stroke="black" points="100.5,-3679 100.5,-3704 283.5,-3704 283.5,-3679 100.5,-3679"/>
-<text text-anchor="start" x="105.5" y="-3688.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="183.5" y="-3688.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="105.5" y="-3688.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_encrypted</text>
+<text text-anchor="start" x="194.5" y="-3688.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="100.5,-3654 100.5,-3679 283.5,-3679 283.5,-3654 100.5,-3654"/>
-<text text-anchor="start" x="105.5" y="-3663.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_encrypted</text>
-<text text-anchor="start" x="194.5" y="-3663.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="105.5" y="-3663.8" font-family="Helvetica,sans-Serif" font-size="14.00">key</text>
+<text text-anchor="start" x="130.5" y="-3663.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
<polygon fill="none" stroke="black" points="100.5,-3629 100.5,-3654 283.5,-3654 283.5,-3629 100.5,-3629"/>
-<text text-anchor="start" x="105.5" y="-3638.8" font-family="Helvetica,sans-Serif" font-size="14.00">key</text>
-<text text-anchor="start" x="130.5" y="-3638.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="100.5,-3604 100.5,-3629 283.5,-3629 283.5,-3604 100.5,-3604"/>
-<text text-anchor="start" x="105.5" y="-3613.8" font-family="Helvetica,sans-Serif" font-size="14.00">val</text>
-<text text-anchor="start" x="126.5" y="-3613.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="105.5" y="-3638.8" font-family="Helvetica,sans-Serif" font-size="14.00">val</text>
+<text text-anchor="start" x="126.5" y="-3638.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
</g>
<!-- serialized_dag -->
<g id="node16" class="node">
<title>serialized_dag</title>
-<polygon fill="none" stroke="black" points="55.5,-3984 55.5,-4012 327.5,-4012 327.5,-3984 55.5,-3984"/>
-<text text-anchor="start" x="128" y="-3995.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
+<polygon fill="none" stroke="black" points="55.5,-4009 55.5,-4037 327.5,-4037 327.5,-4009 55.5,-4009"/>
+<text text-anchor="start" x="128" y="-4020.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
+<polygon fill="none" stroke="black" points="55.5,-3984 55.5,-4009 327.5,-4009 327.5,-3984 55.5,-3984"/>
+<text text-anchor="start" x="60.5" y="-3993.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="106.5" y="-3993.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="227.5" y="-3993.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="55.5,-3959 55.5,-3984 327.5,-3984 327.5,-3959 55.5,-3959"/>
-<text text-anchor="start" x="60.5" y="-3968.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="106.5" y="-3968.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="227.5" y="-3968.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="60.5" y="-3968.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
+<text text-anchor="start" x="127.5" y="-3968.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<text text-anchor="start" x="239.5" y="-3968.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="55.5,-3934 55.5,-3959 327.5,-3959 327.5,-3934 55.5,-3934"/>
-<text text-anchor="start" x="60.5" y="-3943.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
-<text text-anchor="start" x="127.5" y="-3943.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
-<text text-anchor="start" x="239.5" y="-3943.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="60.5" y="-3943.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
+<text text-anchor="start" x="91.5" y="-3943.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
<polygon fill="none" stroke="black" points="55.5,-3909 55.5,-3934 327.5,-3934 327.5,-3909 55.5,-3909"/>
-<text text-anchor="start" x="60.5" y="-3918.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
-<text text-anchor="start" x="91.5" y="-3918.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<text text-anchor="start" x="60.5" y="-3918.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
+<text text-anchor="start" x="182.5" y="-3918.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
<polygon fill="none" stroke="black" points="55.5,-3884 55.5,-3909 327.5,-3909 327.5,-3884 55.5,-3884"/>
-<text text-anchor="start" x="60.5" y="-3893.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
-<text text-anchor="start" x="182.5" y="-3893.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<text text-anchor="start" x="60.5" y="-3893.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
+<text text-anchor="start" x="101.5" y="-3893.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="231.5" y="-3893.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="55.5,-3859 55.5,-3884 327.5,-3884 327.5,-3859 55.5,-3859"/>
-<text text-anchor="start" x="60.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
-<text text-anchor="start" x="101.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<text text-anchor="start" x="231.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="60.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc_hash</text>
+<text text-anchor="start" x="142.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
+<text text-anchor="start" x="206.5" y="-3868.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="55.5,-3834 55.5,-3859 327.5,-3859 327.5,-3834 55.5,-3834"/>
-<text text-anchor="start" x="60.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc_hash</text>
-<text text-anchor="start" x="142.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
-<text text-anchor="start" x="206.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="60.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
+<text text-anchor="start" x="150.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="246.5" y="-3843.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="55.5,-3809 55.5,-3834 327.5,-3834 327.5,-3809 55.5,-3809"/>
-<text text-anchor="start" x="60.5" y="-3818.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
-<text text-anchor="start" x="150.5" y="-3818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="246.5" y="-3818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="55.5,-3784 55.5,-3809 327.5,-3809 327.5,-3784 55.5,-3784"/>
-<text text-anchor="start" x="60.5" y="-3793.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
-<text text-anchor="start" x="179.5" y="-3793.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="60.5" y="-3818.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
+<text text-anchor="start" x="179.5" y="-3818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
</g>
<!-- dataset -->
<g id="node17" class="node">
<title>dataset</title>
-<polygon fill="none" stroke="black" points="61.5,-4868 61.5,-4896 322.5,-4896 322.5,-4868 61.5,-4868"/>
-<text text-anchor="start" x="158" y="-4879.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset</text>
+<polygon fill="none" stroke="black" points="61.5,-4893 61.5,-4921 322.5,-4921 322.5,-4893 61.5,-4893"/>
+<text text-anchor="start" x="158" y="-4904.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset</text>
+<polygon fill="none" stroke="black" points="61.5,-4868 61.5,-4893 322.5,-4893 322.5,-4868 61.5,-4868"/>
+<text text-anchor="start" x="66.5" y="-4877.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="79.5" y="-4877.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="156.5" y="-4877.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="61.5,-4843 61.5,-4868 322.5,-4868 322.5,-4843 61.5,-4843"/>
-<text text-anchor="start" x="66.5" y="-4852.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="79.5" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="156.5" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="66.5" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="139.5" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="235.5" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="61.5,-4818 61.5,-4843 322.5,-4843 322.5,-4818 61.5,-4818"/>
-<text text-anchor="start" x="66.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="139.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="235.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="66.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
+<text text-anchor="start" x="103.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<text text-anchor="start" x="154.5" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="61.5,-4793 61.5,-4818 322.5,-4818 322.5,-4793 61.5,-4793"/>
-<text text-anchor="start" x="66.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00">extra</text>
-<text text-anchor="start" x="103.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<text text-anchor="start" x="154.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="66.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_orphaned</text>
+<text text-anchor="start" x="151.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="235.5" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="61.5,-4768 61.5,-4793 322.5,-4793 322.5,-4768 61.5,-4768"/>
-<text text-anchor="start" x="66.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_orphaned</text>
-<text text-anchor="start" x="151.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<text text-anchor="start" x="235.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="66.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="145.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="241.5" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="61.5,-4743 61.5,-4768 322.5,-4768 322.5,-4743 61.5,-4743"/>
-<text text-anchor="start" x="66.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="145.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="241.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="61.5,-4718 61.5,-4743 322.5,-4743 322.5,-4718 61.5,-4718"/>
-<text text-anchor="start" x="66.5" y="-4727.8" font-family="Helvetica,sans-Serif" font-size="14.00">uri</text>
-<text text-anchor="start" x="85.5" y="-4727.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(3000)]</text>
-<text text-anchor="start" x="215.5" y="-4727.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="66.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00">uri</text>
+<text text-anchor="start" x="85.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(3000)]</text>
+<text text-anchor="start" x="215.5" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_schedule_dataset_reference -->
<g id="node18" class="node">
<title>dag_schedule_dataset_reference</title>
-<polygon fill="none" stroke="black" points="464,-4843 464,-4871 766,-4871 766,-4843 464,-4843"/>
-<text text-anchor="start" x="469" y="-4854.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_schedule_dataset_reference</text>
+<polygon fill="none" stroke="black" points="464,-4868 464,-4896 766,-4896 766,-4868 464,-4868"/>
+<text text-anchor="start" x="469" y="-4879.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_schedule_dataset_reference</text>
+<polygon fill="none" stroke="black" points="464,-4843 464,-4868 766,-4868 766,-4843 464,-4843"/>
+<text text-anchor="start" x="469" y="-4852.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="515" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="636" y="-4852.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="464,-4818 464,-4843 766,-4843 766,-4818 464,-4818"/>
-<text text-anchor="start" x="469" y="-4827.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="515" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="636" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="469" y="-4827.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
+<text text-anchor="start" x="541" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="618" y="-4827.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="464,-4793 464,-4818 766,-4818 766,-4793 464,-4793"/>
-<text text-anchor="start" x="469" y="-4802.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
-<text text-anchor="start" x="541" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="618" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="469" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="542" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="638" y="-4802.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="464,-4768 464,-4793 766,-4793 766,-4768 464,-4768"/>
-<text text-anchor="start" x="469" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="542" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="638" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="464,-4743 464,-4768 766,-4768 766,-4743 464,-4743"/>
-<text text-anchor="start" x="469" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="548" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="644" y="-4752.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="469" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="548" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="644" y="-4777.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dataset--dag_schedule_dataset_reference -->
<g id="edge6" class="edge">
<title>dataset--dag_schedule_dataset_reference</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.22,-4807C370.33,-4807 414.46,-4807 455.73,-4807"/>
-<text text-anchor="start" x="445.73" y="-4795.8" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="330.22" y="-4795.8" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.22,-4832C370.33,-4832 414.46,-4832 455.73,-4832"/>
+<text text-anchor="start" x="445.73" y="-4820.8" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="330.22" y="-4820.8" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_outlet_dataset_reference -->
<g id="node19" class="node">
<title>task_outlet_dataset_reference</title>
-<polygon fill="none" stroke="black" points="475,-4688 475,-4716 756,-4716 756,-4688 475,-4688"/>
-<text text-anchor="start" x="480" y="-4699.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_outlet_dataset_reference</text>
+<polygon fill="none" stroke="black" points="475,-4713 475,-4741 756,-4741 756,-4713 475,-4713"/>
+<text text-anchor="start" x="480" y="-4724.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_outlet_dataset_reference</text>
+<polygon fill="none" stroke="black" points="475,-4688 475,-4713 756,-4713 756,-4688 475,-4688"/>
+<text text-anchor="start" x="480" y="-4697.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="526" y="-4697.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="647" y="-4697.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="475,-4663 475,-4688 756,-4688 756,-4663 475,-4663"/>
-<text text-anchor="start" x="480" y="-4672.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="526" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="647" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="480" y="-4672.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
+<text text-anchor="start" x="552" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="629" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="475,-4638 475,-4663 756,-4663 756,-4638 475,-4638"/>
-<text text-anchor="start" x="480" y="-4647.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
-<text text-anchor="start" x="552" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="629" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="480" y="-4647.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="529" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="650" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="475,-4613 475,-4638 756,-4638 756,-4613 475,-4613"/>
-<text text-anchor="start" x="480" y="-4622.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="529" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="650" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="480" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="553" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="649" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="475,-4588 475,-4613 756,-4613 756,-4588 475,-4588"/>
-<text text-anchor="start" x="480" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="553" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="649" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="475,-4563 475,-4588 756,-4588 756,-4563 475,-4563"/>
-<text text-anchor="start" x="480" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="559" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="655" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="480" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="559" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="655" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dataset--task_outlet_dataset_reference -->
<g id="edge7" class="edge">
<title>dataset--task_outlet_dataset_reference</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.22,-4752.43C373.81,-4735.16 422.16,-4716.01 466.41,-4698.48"/>
-<text text-anchor="start" x="456.41" y="-4687.28" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="330.22" y="-4741.23" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.22,-4777.43C373.81,-4760.16 422.16,-4741.01 466.41,-4723.48"/>
+<text text-anchor="start" x="456.41" y="-4712.28" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="330.22" y="-4766.23" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dataset_dag_run_queue -->
<g id="node20" class="node">
<title>dataset_dag_run_queue</title>
-<polygon fill="none" stroke="black" points="465,-4509 465,-4537 766,-4537 766,-4509 465,-4509"/>
-<text text-anchor="start" x="510" y="-4520.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset_dag_run_queue</text>
+<polygon fill="none" stroke="black" points="465,-4534 465,-4562 766,-4562 766,-4534 465,-4534"/>
+<text text-anchor="start" x="510" y="-4545.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dataset_dag_run_queue</text>
+<polygon fill="none" stroke="black" points="465,-4509 465,-4534 766,-4534 766,-4509 465,-4509"/>
+<text text-anchor="start" x="470" y="-4518.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
+<text text-anchor="start" x="542" y="-4518.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="619" y="-4518.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="465,-4484 465,-4509 766,-4509 766,-4484 465,-4484"/>
-<text text-anchor="start" x="470" y="-4493.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dataset_id</text>
-<text text-anchor="start" x="542" y="-4493.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="619" y="-4493.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="470" y="-4493.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">target_dag_id</text>
+<text text-anchor="start" x="564" y="-4493.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="685" y="-4493.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="465,-4459 465,-4484 766,-4484 766,-4459 465,-4459"/>
-<text text-anchor="start" x="470" y="-4468.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">target_dag_id</text>
-<text text-anchor="start" x="564" y="-4468.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="685" y="-4468.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="465,-4434 465,-4459 766,-4459 766,-4434 465,-4434"/>
-<text text-anchor="start" x="470" y="-4443.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="543" y="-4443.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="639" y="-4443.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="470" y="-4468.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="543" y="-4468.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="639" y="-4468.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dataset--dataset_dag_run_queue -->
<g id="edge8" class="edge">
<title>dataset--dataset_dag_run_queue</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.19,-4747.23C349.39,-4735.09 367.74,-4721.03 383,-4705 435.23,-4650.15 401.06,-4603.14 456,-4551 459.44,-4547.73 463.07,-4544.62 466.85,-4541.66"/>
-<text text-anchor="start" x="456.85" y="-4545.46" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="330.19" y="-4751.03" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M330.19,-4772.23C349.39,-4760.09 367.74,-4746.03 383,-4730 435.23,-4675.15 401.06,-4628.14 456,-4576 459.44,-4572.73 463.07,-4569.62 466.85,-4566.66"/>
+<text text-anchor="start" x="456.85" y="-4570.46" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="330.19" y="-4776.03" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag -->
<g id="node21" class="node">
<title>dag</title>
-<polygon fill="none" stroke="black" points="8.5,-4663 8.5,-4691 375.5,-4691 375.5,-4663 8.5,-4663"/>
-<text text-anchor="start" x="175" y="-4674.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag</text>
+<polygon fill="none" stroke="black" points="8.5,-4688 8.5,-4716 375.5,-4716 375.5,-4688 8.5,-4688"/>
+<text text-anchor="start" x="175" y="-4699.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag</text>
+<polygon fill="none" stroke="black" points="8.5,-4663 8.5,-4688 375.5,-4688 375.5,-4663 8.5,-4663"/>
+<text text-anchor="start" x="13.5" y="-4672.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="59.5" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="180.5" y="-4672.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="8.5,-4638 8.5,-4663 375.5,-4663 375.5,-4638 8.5,-4638"/>
-<text text-anchor="start" x="13.5" y="-4647.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="59.5" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="180.5" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="13.5" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00">default_view</text>
+<text text-anchor="start" x="101.5" y="-4647.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(25)]</text>
<polygon fill="none" stroke="black" points="8.5,-4613 8.5,-4638 375.5,-4638 375.5,-4613 8.5,-4613"/>
-<text text-anchor="start" x="13.5" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00">default_view</text>
-<text text-anchor="start" x="101.5" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(25)]</text>
+<text text-anchor="start" x="13.5" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
+<text text-anchor="start" x="91.5" y="-4622.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
<polygon fill="none" stroke="black" points="8.5,-4588 8.5,-4613 375.5,-4613 375.5,-4588 8.5,-4588"/>
-<text text-anchor="start" x="13.5" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00">description</text>
-<text text-anchor="start" x="91.5" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="13.5" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
+<text text-anchor="start" x="54.5" y="-4597.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
<polygon fill="none" stroke="black" points="8.5,-4563 8.5,-4588 375.5,-4588 375.5,-4563 8.5,-4563"/>
-<text text-anchor="start" x="13.5" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
-<text text-anchor="start" x="54.5" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="13.5" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00">has_import_errors</text>
+<text text-anchor="start" x="138.5" y="-4572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="8.5,-4538 8.5,-4563 375.5,-4563 375.5,-4538 8.5,-4538"/>
-<text text-anchor="start" x="13.5" y="-4547.8" font-family="Helvetica,sans-Serif" font-size="14.00">has_import_errors</text>
-<text text-anchor="start" x="138.5" y="-4547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="13.5" y="-4547.8" font-family="Helvetica,sans-Serif" font-size="14.00">has_task_concurrency_limits</text>
+<text text-anchor="start" x="210.5" y="-4547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="294.5" y="-4547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="8.5,-4513 8.5,-4538 375.5,-4538 375.5,-4513 8.5,-4513"/>
-<text text-anchor="start" x="13.5" y="-4522.8" font-family="Helvetica,sans-Serif" font-size="14.00">has_task_concurrency_limits</text>
-<text text-anchor="start" x="210.5" y="-4522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<text text-anchor="start" x="294.5" y="-4522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="13.5" y="-4522.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_active</text>
+<text text-anchor="start" x="73.5" y="-4522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="8.5,-4488 8.5,-4513 375.5,-4513 375.5,-4488 8.5,-4488"/>
-<text text-anchor="start" x="13.5" y="-4497.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_active</text>
-<text text-anchor="start" x="73.5" y="-4497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="13.5" y="-4497.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_paused</text>
+<text text-anchor="start" x="83.5" y="-4497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="8.5,-4463 8.5,-4488 375.5,-4488 375.5,-4463 8.5,-4463"/>
-<text text-anchor="start" x="13.5" y="-4472.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_paused</text>
+<text text-anchor="start" x="13.5" y="-4472.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_subdag</text>
<text text-anchor="start" x="83.5" y="-4472.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="8.5,-4438 8.5,-4463 375.5,-4463 375.5,-4438 8.5,-4438"/>
-<text text-anchor="start" x="13.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00">is_subdag</text>
-<text text-anchor="start" x="83.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<text text-anchor="start" x="13.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_expired</text>
+<text text-anchor="start" x="97.5" y="-4447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4413 8.5,-4438 375.5,-4438 375.5,-4413 8.5,-4413"/>
-<text text-anchor="start" x="13.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_expired</text>
-<text text-anchor="start" x="97.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_parsed_time</text>
+<text text-anchor="start" x="131.5" y="-4422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4388 8.5,-4413 375.5,-4413 375.5,-4388 8.5,-4388"/>
-<text text-anchor="start" x="13.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_parsed_time</text>
-<text text-anchor="start" x="131.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_pickled</text>
+<text text-anchor="start" x="95.5" y="-4397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4363 8.5,-4388 375.5,-4388 375.5,-4363 8.5,-4363"/>
-<text text-anchor="start" x="13.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_pickled</text>
-<text text-anchor="start" x="95.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_active_runs</text>
+<text text-anchor="start" x="130.5" y="-4372.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
<polygon fill="none" stroke="black" points="8.5,-4338 8.5,-4363 375.5,-4363 375.5,-4338 8.5,-4338"/>
-<text text-anchor="start" x="13.5" y="-4347.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_active_runs</text>
-<text text-anchor="start" x="130.5" y="-4347.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="13.5" y="-4347.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_active_tasks</text>
+<text text-anchor="start" x="135.5" y="-4347.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="212.5" y="-4347.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="8.5,-4313 8.5,-4338 375.5,-4338 375.5,-4313 8.5,-4313"/>
-<text text-anchor="start" x="13.5" y="-4322.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_active_tasks</text>
-<text text-anchor="start" x="135.5" y="-4322.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="212.5" y="-4322.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="13.5" y="-4322.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun</text>
+<text text-anchor="start" x="101.5" y="-4322.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4288 8.5,-4313 375.5,-4313 375.5,-4288 8.5,-4288"/>
-<text text-anchor="start" x="13.5" y="-4297.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun</text>
-<text text-anchor="start" x="101.5" y="-4297.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4297.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_create_after</text>
+<text text-anchor="start" x="190.5" y="-4297.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4263 8.5,-4288 375.5,-4288 375.5,-4263 8.5,-4263"/>
-<text text-anchor="start" x="13.5" y="-4272.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_create_after</text>
-<text text-anchor="start" x="190.5" y="-4272.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4272.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_data_interval_end</text>
+<text text-anchor="start" x="231.5" y="-4272.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4238 8.5,-4263 375.5,-4263 375.5,-4238 8.5,-4238"/>
-<text text-anchor="start" x="13.5" y="-4247.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_data_interval_end</text>
-<text text-anchor="start" x="231.5" y="-4247.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4247.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_data_interval_start</text>
+<text text-anchor="start" x="237.5" y="-4247.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="8.5,-4213 8.5,-4238 375.5,-4238 375.5,-4213 8.5,-4213"/>
-<text text-anchor="start" x="13.5" y="-4222.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_dagrun_data_interval_start</text>
-<text text-anchor="start" x="237.5" y="-4222.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="13.5" y="-4222.8" font-family="Helvetica,sans-Serif" font-size="14.00">owners</text>
+<text text-anchor="start" x="64.5" y="-4222.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
<polygon fill="none" stroke="black" points="8.5,-4188 8.5,-4213 375.5,-4213 375.5,-4188 8.5,-4188"/>
-<text text-anchor="start" x="13.5" y="-4197.8" font-family="Helvetica,sans-Serif" font-size="14.00">owners</text>
-<text text-anchor="start" x="64.5" y="-4197.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="13.5" y="-4197.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle_id</text>
+<text text-anchor="start" x="74.5" y="-4197.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
<polygon fill="none" stroke="black" points="8.5,-4163 8.5,-4188 375.5,-4188 375.5,-4163 8.5,-4163"/>
-<text text-anchor="start" x="13.5" y="-4172.8" font-family="Helvetica,sans-Serif" font-size="14.00">pickle_id</text>
-<text text-anchor="start" x="74.5" y="-4172.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="13.5" y="-4172.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
+<text text-anchor="start" x="132.5" y="-4172.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
<polygon fill="none" stroke="black" points="8.5,-4138 8.5,-4163 375.5,-4163 375.5,-4138 8.5,-4138"/>
-<text text-anchor="start" x="13.5" y="-4147.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
-<text text-anchor="start" x="132.5" y="-4147.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="13.5" y="-4147.8" font-family="Helvetica,sans-Serif" font-size="14.00">root_dag_id</text>
+<text text-anchor="start" x="93.5" y="-4147.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
<polygon fill="none" stroke="black" points="8.5,-4113 8.5,-4138 375.5,-4138 375.5,-4113 8.5,-4113"/>
-<text text-anchor="start" x="13.5" y="-4122.8" font-family="Helvetica,sans-Serif" font-size="14.00">root_dag_id</text>
-<text text-anchor="start" x="93.5" y="-4122.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="13.5" y="-4122.8" font-family="Helvetica,sans-Serif" font-size="14.00">schedule_interval</text>
+<text text-anchor="start" x="135.5" y="-4122.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
<polygon fill="none" stroke="black" points="8.5,-4088 8.5,-4113 375.5,-4113 375.5,-4088 8.5,-4088"/>
-<text text-anchor="start" x="13.5" y="-4097.8" font-family="Helvetica,sans-Serif" font-size="14.00">schedule_interval</text>
-<text text-anchor="start" x="135.5" y="-4097.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="13.5" y="-4097.8" font-family="Helvetica,sans-Serif" font-size="14.00">scheduler_lock</text>
+<text text-anchor="start" x="116.5" y="-4097.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
<polygon fill="none" stroke="black" points="8.5,-4063 8.5,-4088 375.5,-4088 375.5,-4063 8.5,-4063"/>
-<text text-anchor="start" x="13.5" y="-4072.8" font-family="Helvetica,sans-Serif" font-size="14.00">scheduler_lock</text>
-<text text-anchor="start" x="116.5" y="-4072.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="8.5,-4038 8.5,-4063 375.5,-4063 375.5,-4038 8.5,-4038"/>
-<text text-anchor="start" x="13.5" y="-4047.8" font-family="Helvetica,sans-Serif" font-size="14.00">timetable_description</text>
-<text text-anchor="start" x="163.5" y="-4047.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<text text-anchor="start" x="13.5" y="-4072.8" font-family="Helvetica,sans-Serif" font-size="14.00">timetable_description</text>
+<text text-anchor="start" x="163.5" y="-4072.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
</g>
<!-- dag--dag_schedule_dataset_reference -->
<g id="edge9" class="edge">
<title>dag--dag_schedule_dataset_reference</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.19,-4658.08C406.06,-4683.98 430.43,-4708.49 456,-4730 459.62,-4733.05 463.38,-4736 467.25,-4738.88"/>
-<text text-anchor="start" x="457.25" y="-4727.68" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.19" y="-4646.88" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.19,-4683.08C406.06,-4708.98 430.43,-4733.49 456,-4755 459.62,-4758.05 463.38,-4761 467.25,-4763.88"/>
+<text text-anchor="start" x="457.25" y="-4752.68" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.19" y="-4671.88" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag--task_outlet_dataset_reference -->
<g id="edge10" class="edge">
<title>dag--task_outlet_dataset_reference</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.08,-4502.93C407.37,-4519.5 432.1,-4535.89 456,-4551 460.39,-4553.78 464.87,-4556.56 469.41,-4559.35"/>
-<text text-anchor="start" x="469.41" y="-4548.15" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.08" y="-4491.73" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.08,-4527.93C407.37,-4544.5 432.1,-4560.89 456,-4576 460.39,-4578.78 464.87,-4581.56 469.41,-4584.35"/>
+<text text-anchor="start" x="469.41" y="-4573.15" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.08" y="-4516.73" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag--dataset_dag_run_queue -->
<g id="edge11" class="edge">
<title>dag--dataset_dag_run_queue</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4419.75C407.63,-4426.76 432.4,-4433.87 456.22,-4440.7"/>
-<text text-anchor="start" x="446.22" y="-4429.5" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.21" y="-4408.55" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4444.75C407.63,-4451.76 432.4,-4458.87 456.22,-4465.7"/>
+<text text-anchor="start" x="446.22" y="-4454.5" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.21" y="-4433.55" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_tag -->
<g id="node22" class="node">
<title>dag_tag</title>
-<polygon fill="none" stroke="black" points="489,-4380 489,-4408 742,-4408 742,-4380 489,-4380"/>
-<text text-anchor="start" x="580" y="-4391.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_tag</text>
+<polygon fill="none" stroke="black" points="489,-4405 489,-4433 742,-4433 742,-4405 489,-4405"/>
+<text text-anchor="start" x="580" y="-4416.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_tag</text>
+<polygon fill="none" stroke="black" points="489,-4380 489,-4405 742,-4405 742,-4380 489,-4380"/>
+<text text-anchor="start" x="494" y="-4389.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="540" y="-4389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="661" y="-4389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="489,-4355 489,-4380 742,-4380 742,-4355 489,-4355"/>
-<text text-anchor="start" x="494" y="-4364.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="540" y="-4364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="661" y="-4364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="489,-4330 489,-4355 742,-4355 742,-4330 489,-4330"/>
-<text text-anchor="start" x="494" y="-4339.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">name</text>
-<text text-anchor="start" x="534" y="-4339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(100)]</text>
-<text text-anchor="start" x="655" y="-4339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="494" y="-4364.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">name</text>
+<text text-anchor="start" x="534" y="-4364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(100)]</text>
+<text text-anchor="start" x="655" y="-4364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag--dag_tag -->
<g id="edge12" class="edge">
<title>dag--dag_tag</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4366.81C416.02,-4367.12 449.48,-4367.44 480.38,-4367.73"/>
-<text text-anchor="start" x="470.38" y="-4356.53" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.21" y="-4355.61" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4391.81C416.02,-4392.12 449.48,-4392.44 480.38,-4392.73"/>
+<text text-anchor="start" x="470.38" y="-4381.53" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.21" y="-4380.61" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_owner_attributes -->
<g id="node23" class="node">
<title>dag_owner_attributes</title>
-<polygon fill="none" stroke="black" points="489,-4275 489,-4303 742,-4303 742,-4275 489,-4275"/>
-<text text-anchor="start" x="517.5" y="-4286.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_owner_attributes</text>
+<polygon fill="none" stroke="black" points="489,-4300 489,-4328 742,-4328 742,-4300 489,-4300"/>
+<text text-anchor="start" x="517.5" y="-4311.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_owner_attributes</text>
+<polygon fill="none" stroke="black" points="489,-4275 489,-4300 742,-4300 742,-4275 489,-4275"/>
+<text text-anchor="start" x="494" y="-4284.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="540" y="-4284.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="661" y="-4284.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="489,-4250 489,-4275 742,-4275 742,-4250 489,-4250"/>
-<text text-anchor="start" x="494" y="-4259.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="540" y="-4259.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="661" y="-4259.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="494" y="-4259.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">owner</text>
+<text text-anchor="start" x="537" y="-4259.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
+<text text-anchor="start" x="658" y="-4259.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="489,-4225 489,-4250 742,-4250 742,-4225 489,-4225"/>
-<text text-anchor="start" x="494" y="-4234.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">owner</text>
-<text text-anchor="start" x="537" y="-4234.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
-<text text-anchor="start" x="658" y="-4234.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="489,-4200 489,-4225 742,-4225 742,-4200 489,-4200"/>
-<text text-anchor="start" x="494" y="-4209.8" font-family="Helvetica,sans-Serif" font-size="14.00">link</text>
-<text text-anchor="start" x="519" y="-4209.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
-<text text-anchor="start" x="640" y="-4209.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="494" y="-4234.8" font-family="Helvetica,sans-Serif" font-size="14.00">link</text>
+<text text-anchor="start" x="519" y="-4234.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(500)]</text>
+<text text-anchor="start" x="640" y="-4234.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag--dag_owner_attributes -->
<g id="edge13" class="edge">
<title>dag--dag_owner_attributes</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4313.87C416.02,-4305.08 449.48,-4296.11 480.38,-4287.82"/>
-<text text-anchor="start" x="470.38" y="-4276.62" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.21" y="-4302.67" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.21,-4338.87C416.02,-4330.08 449.48,-4321.11 480.38,-4312.82"/>
+<text text-anchor="start" x="470.38" y="-4301.62" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.21" y="-4327.67" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_warning -->
<g id="node24" class="node">
<title>dag_warning</title>
-<polygon fill="none" stroke="black" points="469,-4146 469,-4174 761,-4174 761,-4146 469,-4146"/>
-<text text-anchor="start" x="557.5" y="-4157.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_warning</text>
+<polygon fill="none" stroke="black" points="469,-4171 469,-4199 761,-4199 761,-4171 469,-4171"/>
+<text text-anchor="start" x="557.5" y="-4182.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_warning</text>
+<polygon fill="none" stroke="black" points="469,-4146 469,-4171 761,-4171 761,-4146 469,-4146"/>
+<text text-anchor="start" x="474" y="-4155.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="520" y="-4155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="641" y="-4155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="469,-4121 469,-4146 761,-4146 761,-4121 469,-4121"/>
-<text text-anchor="start" x="474" y="-4130.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="520" y="-4130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="641" y="-4130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="474" y="-4130.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">warning_type</text>
+<text text-anchor="start" x="568" y="-4130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<text text-anchor="start" x="680" y="-4130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="469,-4096 469,-4121 761,-4121 761,-4096 469,-4096"/>
-<text text-anchor="start" x="474" y="-4105.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">warning_type</text>
-<text text-anchor="start" x="568" y="-4105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
-<text text-anchor="start" x="680" y="-4105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="474" y="-4105.8" font-family="Helvetica,sans-Serif" font-size="14.00">message</text>
+<text text-anchor="start" x="537" y="-4105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="587" y="-4105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="469,-4071 469,-4096 761,-4096 761,-4071 469,-4071"/>
-<text text-anchor="start" x="474" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00">message</text>
-<text text-anchor="start" x="537" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<text text-anchor="start" x="587" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="469,-4046 469,-4071 761,-4071 761,-4046 469,-4046"/>
-<text text-anchor="start" x="474" y="-4055.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="549" y="-4055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="645" y="-4055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="474" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="549" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="645" y="-4080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag--dag_warning -->
<g id="edge14" class="edge">
<title>dag--dag_warning</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.09,-4232.68C407.33,-4217.13 432.04,-4201.88 456,-4188 461.69,-4184.7 467.54,-4181.41 473.48,-4178.14"/>
-<text text-anchor="start" x="463.48" y="-4181.94" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="383.09" y="-4221.48" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M383.09,-4257.68C407.33,-4242.13 432.04,-4226.88 456,-4213 461.69,-4209.7 467.54,-4206.41 473.48,-4203.14"/>
+<text text-anchor="start" x="463.48" y="-4206.94" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="383.09" y="-4246.48" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- log_template -->
<g id="node25" class="node">
@@ -924,548 +927,507 @@
<!-- dag_run--dag_run_note -->
<g id="edge19" class="edge">
<title>dag_run--dag_run_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.59,-1249.44C799.88,-1268.33 834.98,-1288.25 867.73,-1306.83"/>
-<text text-anchor="start" x="857.73" y="-1295.63" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="766.59" y="-1238.24" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.63,-1249.96C800.89,-1269.52 837.12,-1290.2 870.82,-1309.42"/>
+<text text-anchor="start" x="860.82" y="-1298.22" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="766.63" y="-1238.76" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dagrun_dataset_event -->
<g id="node27" class="node">
<title>dagrun_dataset_event</title>
-<polygon fill="none" stroke="black" points="886.5,-1551 886.5,-1579 1126.5,-1579 1126.5,-1551 886.5,-1551"/>
-<text text-anchor="start" x="907" y="-1562.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_dataset_event</text>
-<polygon fill="none" stroke="black" points="886.5,-1526 886.5,-1551 1126.5,-1551 1126.5,-1526 886.5,-1526"/>
-<text text-anchor="start" x="891.5" y="-1535.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="968.5" y="-1535.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1045.5" y="-1535.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="886.5,-1501 886.5,-1526 1126.5,-1526 1126.5,-1501 886.5,-1501"/>
-<text text-anchor="start" x="891.5" y="-1510.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
-<text text-anchor="start" x="950.5" y="-1510.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1027.5" y="-1510.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="889.5,-1551 889.5,-1579 1129.5,-1579 1129.5,-1551 889.5,-1551"/>
+<text text-anchor="start" x="910" y="-1562.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_dataset_event</text>
+<polygon fill="none" stroke="black" points="889.5,-1526 889.5,-1551 1129.5,-1551 1129.5,-1526 889.5,-1526"/>
+<text text-anchor="start" x="894.5" y="-1535.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="971.5" y="-1535.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1048.5" y="-1535.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="889.5,-1501 889.5,-1526 1129.5,-1526 1129.5,-1501 889.5,-1501"/>
+<text text-anchor="start" x="894.5" y="-1510.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
+<text text-anchor="start" x="953.5" y="-1510.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1030.5" y="-1510.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_run--dagrun_dataset_event -->
<g id="edge16" class="edge">
<title>dag_run--dagrun_dataset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.78,-1396.41C791.38,-1424.78 818.29,-1451.6 847,-1474 857.93,-1482.53 870.12,-1490.13 882.75,-1496.87"/>
-<text text-anchor="start" x="872.75" y="-1485.67" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="766.78" y="-1385.21" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.76,-1400.08C791.28,-1428.33 818.18,-1454.93 847,-1477 857.51,-1485.05 869.18,-1492.19 881.3,-1498.51"/>
+<text text-anchor="start" x="871.3" y="-1487.31" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="766.76" y="-1388.88" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance -->
<g id="node28" class="node">
<title>task_instance</title>
-<polygon fill="none" stroke="black" points="855.5,-1171 855.5,-1199 1158.5,-1199 1158.5,-1171 855.5,-1171"/>
-<text text-anchor="start" x="945.5" y="-1182.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
-<polygon fill="none" stroke="black" points="855.5,-1146 855.5,-1171 1158.5,-1171 1158.5,-1146 855.5,-1146"/>
-<text text-anchor="start" x="860.5" y="-1155.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="906.5" y="-1155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1027.5" y="-1155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-1121 855.5,-1146 1158.5,-1146 1158.5,-1121 855.5,-1121"/>
-<text text-anchor="start" x="860.5" y="-1130.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="936.5" y="-1130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1013.5" y="-1130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-1096 855.5,-1121 1158.5,-1121 1158.5,-1096 855.5,-1096"/>
-<text text-anchor="start" x="860.5" y="-1105.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="904.5" y="-1105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1025.5" y="-1105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-1071 855.5,-1096 1158.5,-1096 1158.5,-1071 855.5,-1071"/>
-<text text-anchor="start" x="860.5" y="-1080.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="909.5" y="-1080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1030.5" y="-1080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-1046 855.5,-1071 1158.5,-1071 1158.5,-1046 855.5,-1046"/>
-<text text-anchor="start" x="860.5" y="-1055.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
-<text text-anchor="start" x="1023.5" y="-1055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855.5,-1021 855.5,-1046 1158.5,-1046 1158.5,-1021 855.5,-1021"/>
-<text text-anchor="start" x="860.5" y="-1030.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="919.5" y="-1030.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
-<polygon fill="none" stroke="black" points="855.5,-996 855.5,-1021 1158.5,-1021 1158.5,-996 855.5,-996"/>
-<text text-anchor="start" x="860.5" y="-1005.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="924.5" y="-1005.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855.5,-971 855.5,-996 1158.5,-996 1158.5,-971 855.5,-971"/>
-<text text-anchor="start" x="860.5" y="-980.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
-<text text-anchor="start" x="970.5" y="-980.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
-<polygon fill="none" stroke="black" points="855.5,-946 855.5,-971 1158.5,-971 1158.5,-946 855.5,-946"/>
-<text text-anchor="start" x="860.5" y="-955.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
-<text text-anchor="start" x="1003.5" y="-955.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="855.5,-921 855.5,-946 1158.5,-946 1158.5,-921 855.5,-921"/>
-<text text-anchor="start" x="860.5" y="-930.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
-<text text-anchor="start" x="930.5" y="-930.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855.5,-896 855.5,-921 1158.5,-921 1158.5,-896 855.5,-896"/>
-<text text-anchor="start" x="860.5" y="-905.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_id</text>
-<text text-anchor="start" x="901.5" y="-905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-871 855.5,-896 1158.5,-896 1158.5,-871 855.5,-871"/>
-<text text-anchor="start" x="860.5" y="-880.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
-<text text-anchor="start" x="928.5" y="-880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-846 855.5,-871 1158.5,-871 1158.5,-846 855.5,-846"/>
-<text text-anchor="start" x="860.5" y="-855.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
-<text text-anchor="start" x="948.5" y="-855.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="855.5,-821 855.5,-846 1158.5,-846 1158.5,-821 855.5,-821"/>
-<text text-anchor="start" x="860.5" y="-830.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
-<text text-anchor="start" x="951.5" y="-830.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855.5,-796 855.5,-821 1158.5,-821 1158.5,-796 855.5,-796"/>
-<text text-anchor="start" x="860.5" y="-805.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
-<text text-anchor="start" x="920.5" y="-805.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855.5,-771 855.5,-796 1158.5,-796 1158.5,-771 855.5,-771"/>
-<text text-anchor="start" x="860.5" y="-780.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
-<text text-anchor="start" x="882.5" y="-780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-746 855.5,-771 1158.5,-771 1158.5,-746 855.5,-746"/>
-<text text-anchor="start" x="860.5" y="-755.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
-<text text-anchor="start" x="890.5" y="-755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<text text-anchor="start" x="1011.5" y="-755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-721 855.5,-746 1158.5,-746 1158.5,-721 855.5,-721"/>
-<text text-anchor="start" x="860.5" y="-730.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
-<text text-anchor="start" x="929.5" y="-730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1006.5" y="-730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="855.5,-696 855.5,-721 1158.5,-721 1158.5,-696 855.5,-696"/>
-<text text-anchor="start" x="860.5" y="-705.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
-<text text-anchor="start" x="964.5" y="-705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-671 855.5,-696 1158.5,-696 1158.5,-671 855.5,-671"/>
-<text text-anchor="start" x="860.5" y="-680.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
-<text text-anchor="start" x="904.5" y="-680.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<polygon fill="none" stroke="black" points="855.5,-646 855.5,-671 1158.5,-671 1158.5,-646 855.5,-646"/>
-<text text-anchor="start" x="860.5" y="-655.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
-<text text-anchor="start" x="984.5" y="-655.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-621 855.5,-646 1158.5,-646 1158.5,-621 855.5,-621"/>
-<text text-anchor="start" x="860.5" y="-630.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
-<text text-anchor="start" x="953.5" y="-630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855.5,-596 855.5,-621 1158.5,-621 1158.5,-596 855.5,-596"/>
-<text text-anchor="start" x="860.5" y="-605.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="930.5" y="-605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855.5,-571 855.5,-596 1158.5,-596 1158.5,-571 855.5,-571"/>
-<text text-anchor="start" x="860.5" y="-580.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="895.5" y="-580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
-<polygon fill="none" stroke="black" points="855.5,-546 855.5,-571 1158.5,-571 1158.5,-546 855.5,-546"/>
-<text text-anchor="start" x="860.5" y="-555.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
-<text text-anchor="start" x="927.5" y="-555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-521 855.5,-546 1158.5,-546 1158.5,-521 855.5,-521"/>
-<text text-anchor="start" x="860.5" y="-530.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
-<text text-anchor="start" x="968.5" y="-530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="855.5,-496 855.5,-521 1158.5,-521 1158.5,-496 855.5,-496"/>
-<text text-anchor="start" x="860.5" y="-505.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="942.5" y="-505.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="855.5,-471 855.5,-496 1158.5,-496 1158.5,-471 855.5,-471"/>
-<text text-anchor="start" x="860.5" y="-480.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
-<text text-anchor="start" x="930.5" y="-480.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="855.5,-446 855.5,-471 1158.5,-471 1158.5,-446 855.5,-446"/>
-<text text-anchor="start" x="860.5" y="-455.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="939.5" y="-455.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855.5,-1181 855.5,-1209 1164.5,-1209 1164.5,-1181 855.5,-1181"/>
+<text text-anchor="start" x="948.5" y="-1192.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
+<polygon fill="none" stroke="black" points="855.5,-1156 855.5,-1181 1164.5,-1181 1164.5,-1156 855.5,-1156"/>
+<text text-anchor="start" x="860.5" y="-1165.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="906.5" y="-1165.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1027.5" y="-1165.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-1131 855.5,-1156 1164.5,-1156 1164.5,-1131 855.5,-1131"/>
+<text text-anchor="start" x="860.5" y="-1140.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="936.5" y="-1140.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1013.5" y="-1140.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-1106 855.5,-1131 1164.5,-1131 1164.5,-1106 855.5,-1106"/>
+<text text-anchor="start" x="860.5" y="-1115.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="904.5" y="-1115.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1025.5" y="-1115.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-1081 855.5,-1106 1164.5,-1106 1164.5,-1081 855.5,-1081"/>
+<text text-anchor="start" x="860.5" y="-1090.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="909.5" y="-1090.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1030.5" y="-1090.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-1056 855.5,-1081 1164.5,-1081 1164.5,-1056 855.5,-1056"/>
+<text text-anchor="start" x="860.5" y="-1065.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
+<text text-anchor="start" x="1023.5" y="-1065.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-1031 855.5,-1056 1164.5,-1056 1164.5,-1031 855.5,-1031"/>
+<text text-anchor="start" x="860.5" y="-1040.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="919.5" y="-1040.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
+<polygon fill="none" stroke="black" points="855.5,-1006 855.5,-1031 1164.5,-1031 1164.5,-1006 855.5,-1006"/>
+<text text-anchor="start" x="860.5" y="-1015.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="924.5" y="-1015.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855.5,-981 855.5,-1006 1164.5,-1006 1164.5,-981 855.5,-981"/>
+<text text-anchor="start" x="860.5" y="-990.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
+<text text-anchor="start" x="970.5" y="-990.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="855.5,-956 855.5,-981 1164.5,-981 1164.5,-956 855.5,-956"/>
+<text text-anchor="start" x="860.5" y="-965.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
+<text text-anchor="start" x="1003.5" y="-965.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="855.5,-931 855.5,-956 1164.5,-956 1164.5,-931 855.5,-931"/>
+<text text-anchor="start" x="860.5" y="-940.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
+<text text-anchor="start" x="930.5" y="-940.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-906 855.5,-931 1164.5,-931 1164.5,-906 855.5,-906"/>
+<text text-anchor="start" x="860.5" y="-915.8" font-family="Helvetica,sans-Serif" font-size="14.00">job_id</text>
+<text text-anchor="start" x="901.5" y="-915.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-881 855.5,-906 1164.5,-906 1164.5,-881 855.5,-881"/>
+<text text-anchor="start" x="860.5" y="-890.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
+<text text-anchor="start" x="928.5" y="-890.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-856 855.5,-881 1164.5,-881 1164.5,-856 855.5,-856"/>
+<text text-anchor="start" x="860.5" y="-865.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
+<text text-anchor="start" x="948.5" y="-865.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="855.5,-831 855.5,-856 1164.5,-856 1164.5,-831 855.5,-831"/>
+<text text-anchor="start" x="860.5" y="-840.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
+<text text-anchor="start" x="951.5" y="-840.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-806 855.5,-831 1164.5,-831 1164.5,-806 855.5,-806"/>
+<text text-anchor="start" x="860.5" y="-815.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
+<text text-anchor="start" x="920.5" y="-815.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-781 855.5,-806 1164.5,-806 1164.5,-781 855.5,-781"/>
+<text text-anchor="start" x="860.5" y="-790.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
+<text text-anchor="start" x="882.5" y="-790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-756 855.5,-781 1164.5,-781 1164.5,-756 855.5,-756"/>
+<text text-anchor="start" x="860.5" y="-765.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
+<text text-anchor="start" x="890.5" y="-765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<text text-anchor="start" x="1011.5" y="-765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-731 855.5,-756 1164.5,-756 1164.5,-731 855.5,-731"/>
+<text text-anchor="start" x="860.5" y="-740.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
+<text text-anchor="start" x="929.5" y="-740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1006.5" y="-740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="855.5,-706 855.5,-731 1164.5,-731 1164.5,-706 855.5,-706"/>
+<text text-anchor="start" x="860.5" y="-715.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
+<text text-anchor="start" x="964.5" y="-715.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-681 855.5,-706 1164.5,-706 1164.5,-681 855.5,-681"/>
+<text text-anchor="start" x="860.5" y="-690.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight_strategy</text>
+<text text-anchor="start" x="1029.5" y="-690.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-656 855.5,-681 1164.5,-681 1164.5,-656 855.5,-656"/>
+<text text-anchor="start" x="860.5" y="-665.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
+<text text-anchor="start" x="904.5" y="-665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<polygon fill="none" stroke="black" points="855.5,-631 855.5,-656 1164.5,-656 1164.5,-631 855.5,-631"/>
+<text text-anchor="start" x="860.5" y="-640.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
+<text text-anchor="start" x="984.5" y="-640.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-606 855.5,-631 1164.5,-631 1164.5,-606 855.5,-606"/>
+<text text-anchor="start" x="860.5" y="-615.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
+<text text-anchor="start" x="953.5" y="-615.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855.5,-581 855.5,-606 1164.5,-606 1164.5,-581 855.5,-581"/>
+<text text-anchor="start" x="860.5" y="-590.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="930.5" y="-590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855.5,-556 855.5,-581 1164.5,-581 1164.5,-556 855.5,-556"/>
+<text text-anchor="start" x="860.5" y="-565.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="895.5" y="-565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
+<polygon fill="none" stroke="black" points="855.5,-531 855.5,-556 1164.5,-556 1164.5,-531 855.5,-531"/>
+<text text-anchor="start" x="860.5" y="-540.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
+<text text-anchor="start" x="927.5" y="-540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-506 855.5,-531 1164.5,-531 1164.5,-506 855.5,-506"/>
+<text text-anchor="start" x="860.5" y="-515.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
+<text text-anchor="start" x="968.5" y="-515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="855.5,-481 855.5,-506 1164.5,-506 1164.5,-481 855.5,-481"/>
+<text text-anchor="start" x="860.5" y="-490.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="942.5" y="-490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="855.5,-456 855.5,-481 1164.5,-481 1164.5,-456 855.5,-456"/>
+<text text-anchor="start" x="860.5" y="-465.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
+<text text-anchor="start" x="930.5" y="-465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="855.5,-431 855.5,-456 1164.5,-456 1164.5,-431 855.5,-431"/>
+<text text-anchor="start" x="860.5" y="-440.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="939.5" y="-440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</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.59,-1025.57C792.92,-1002.33 820.39,-978.26 846.93,-955.18"/>
-<text text-anchor="start" x="836.93" y="-943.98" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="766.59" y="-1014.37" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.63,-1025.4C792.89,-1002.19 820.32,-978.13 846.86,-955.01"/>
+<text text-anchor="start" x="836.86" y="-943.81" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="766.63" y="-1014.2" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_instance -->
<g id="edge18" class="edge">
<title>dag_run--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.59,-1038.75C792.92,-1015.89 820.39,-991.86 846.93,-968.47"/>
-<text text-anchor="start" x="836.93" y="-972.27" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="766.59" y="-1042.55" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.63,-1038.57C792.89,-1015.74 820.32,-991.73 846.86,-968.32"/>
+<text text-anchor="start" x="836.86" y="-972.12" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="766.63" y="-1042.37" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_reschedule -->
<g id="node29" class="node">
<title>task_reschedule</title>
-<polygon fill="none" stroke="black" points="1247,-1352 1247,-1380 1543,-1380 1543,-1352 1247,-1352"/>
-<text text-anchor="start" x="1322.5" y="-1363.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_reschedule</text>
-<polygon fill="none" stroke="black" points="1247,-1327 1247,-1352 1543,-1352 1543,-1327 1247,-1327"/>
-<text text-anchor="start" x="1252" y="-1336.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1265" y="-1336.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1342" y="-1336.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1302 1247,-1327 1543,-1327 1543,-1302 1247,-1302"/>
-<text text-anchor="start" x="1252" y="-1311.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1298" y="-1311.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1419" y="-1311.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1277 1247,-1302 1543,-1302 1543,-1277 1247,-1277"/>
-<text text-anchor="start" x="1252" y="-1286.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="1311" y="-1286.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1388" y="-1286.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1252 1247,-1277 1543,-1277 1543,-1252 1247,-1252"/>
-<text text-anchor="start" x="1252" y="-1261.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1316" y="-1261.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1412" y="-1261.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1227 1247,-1252 1543,-1252 1543,-1227 1247,-1227"/>
-<text text-anchor="start" x="1252" y="-1236.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1328" y="-1236.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1405" y="-1236.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1202 1247,-1227 1543,-1227 1543,-1202 1247,-1202"/>
-<text text-anchor="start" x="1252" y="-1211.8" font-family="Helvetica,sans-Serif" font-size="14.00">reschedule_date</text>
-<text text-anchor="start" x="1366" y="-1211.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1462" y="-1211.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1177 1247,-1202 1543,-1202 1543,-1177 1247,-1177"/>
-<text text-anchor="start" x="1252" y="-1186.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1296" y="-1186.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1417" y="-1186.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1152 1247,-1177 1543,-1177 1543,-1152 1247,-1152"/>
-<text text-anchor="start" x="1252" y="-1161.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1322" y="-1161.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1418" y="-1161.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1127 1247,-1152 1543,-1152 1543,-1127 1247,-1127"/>
-<text text-anchor="start" x="1252" y="-1136.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1301" y="-1136.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1422" y="-1136.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1247,-1102 1247,-1127 1543,-1127 1543,-1102 1247,-1102"/>
-<text text-anchor="start" x="1252" y="-1111.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="1334" y="-1111.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1411" y="-1111.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1361 1253,-1389 1549,-1389 1549,-1361 1253,-1361"/>
+<text text-anchor="start" x="1328.5" y="-1372.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_reschedule</text>
+<polygon fill="none" stroke="black" points="1253,-1336 1253,-1361 1549,-1361 1549,-1336 1253,-1336"/>
+<text text-anchor="start" x="1258" y="-1345.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1271" y="-1345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1348" y="-1345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1311 1253,-1336 1549,-1336 1549,-1311 1253,-1311"/>
+<text text-anchor="start" x="1258" y="-1320.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1304" y="-1320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1425" y="-1320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1286 1253,-1311 1549,-1311 1549,-1286 1253,-1286"/>
+<text text-anchor="start" x="1258" y="-1295.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="1317" y="-1295.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1394" y="-1295.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1261 1253,-1286 1549,-1286 1549,-1261 1253,-1261"/>
+<text text-anchor="start" x="1258" y="-1270.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1322" y="-1270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1418" y="-1270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1236 1253,-1261 1549,-1261 1549,-1236 1253,-1236"/>
+<text text-anchor="start" x="1258" y="-1245.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1334" y="-1245.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1411" y="-1245.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1211 1253,-1236 1549,-1236 1549,-1211 1253,-1211"/>
+<text text-anchor="start" x="1258" y="-1220.8" font-family="Helvetica,sans-Serif" font-size="14.00">reschedule_date</text>
+<text text-anchor="start" x="1372" y="-1220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1468" y="-1220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1186 1253,-1211 1549,-1211 1549,-1186 1253,-1186"/>
+<text text-anchor="start" x="1258" y="-1195.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1302" y="-1195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1423" y="-1195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1161 1253,-1186 1549,-1186 1549,-1161 1253,-1161"/>
+<text text-anchor="start" x="1258" y="-1170.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1328" y="-1170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1424" y="-1170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1136 1253,-1161 1549,-1161 1549,-1136 1253,-1136"/>
+<text text-anchor="start" x="1258" y="-1145.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1307" y="-1145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1428" y="-1145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1253,-1111 1253,-1136 1549,-1136 1549,-1111 1253,-1111"/>
+<text text-anchor="start" x="1258" y="-1120.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="1340" y="-1120.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1417" y="-1120.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_run--task_reschedule -->
<g id="edge20" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.72,-1189.89C793.35,-1194.91 820.9,-1199.62 847,-1203 978.56,-1220.06 1129.17,-1227.13 1239,-1231.5"/>
-<text text-anchor="start" x="1208" y="-1220.3" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.72" y="-1178.69" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.74,-1197.48C793.3,-1203.51 820.83,-1209.09 847,-1213 980.34,-1232.92 1133.56,-1239.42 1244.85,-1242.7"/>
+<text text-anchor="start" x="1213.85" y="-1231.5" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.74" y="-1186.28" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_reschedule -->
<g id="edge21" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.72,-1207.61C793.35,-1212.91 820.9,-1217.62 847,-1221 978.56,-1238.06 1129.17,-1245.13 1239,-1246.59"/>
-<text text-anchor="start" x="1208" y="-1235.39" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="766.72" y="-1196.41" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M766.74,-1215.2C793.3,-1221.51 820.83,-1227.09 847,-1231 980.34,-1250.92 1133.56,-1257.42 1244.85,-1257.74"/>
+<text text-anchor="start" x="1213.85" y="-1246.54" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="766.74" y="-1204" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge45" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1143.49,-1203.78C1170.82,-1260.57 1202.57,-1316.56 1239,-1366 1248.18,-1378.46 1258.86,-1390.43 1270.23,-1401.84"/>
-<text text-anchor="start" x="1260.23" y="-1390.64" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1133.49" y="-1207.58" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1149.74,-1213.15C1177.06,-1269.84 1208.72,-1325.62 1245,-1375 1254.17,-1387.48 1264.83,-1399.45 1276.19,-1410.87"/>
+<text text-anchor="start" x="1266.19" y="-1399.67" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1139.74" y="-1216.95" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge46" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1135.08,-1203.71C1164.25,-1266.82 1198.76,-1329.4 1239,-1384 1244.37,-1391.28 1250.24,-1398.39 1256.47,-1405.31"/>
-<text text-anchor="start" x="1246.47" y="-1394.11" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1125.08" y="-1207.51" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1141.32,-1213.1C1170.49,-1276.12 1204.93,-1338.46 1245,-1393 1250.36,-1400.29 1256.22,-1407.41 1262.44,-1414.32"/>
+<text text-anchor="start" x="1252.44" y="-1403.12" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1131.32" y="-1216.9" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge47" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1127.13,-1203.82C1157.91,-1273.17 1195.04,-1342.35 1239,-1402 1244.37,-1409.28 1250.24,-1416.39 1256.47,-1423.29"/>
-<text text-anchor="start" x="1246.47" y="-1412.09" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1117.13" y="-1207.62" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1133.36,-1213.26C1164.17,-1282.51 1201.22,-1351.42 1245,-1411 1250.36,-1418.29 1256.22,-1425.41 1262.44,-1432.31"/>
+<text text-anchor="start" x="1252.44" y="-1421.11" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1123.36" y="-1217.06" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge48" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1119.44,-1203.75C1151.67,-1279.38 1191.32,-1355.3 1239,-1420 1244.37,-1427.28 1250.24,-1434.39 1256.47,-1441.27"/>
-<text text-anchor="start" x="1246.47" y="-1430.07" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1109.44" y="-1207.55" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1125.66,-1213.23C1157.94,-1288.77 1197.51,-1364.37 1245,-1429 1250.36,-1436.29 1256.22,-1443.41 1262.44,-1450.29"/>
+<text text-anchor="start" x="1252.44" y="-1439.09" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1115.66" y="-1217.03" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge37" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.3,-982.57C1190.32,-1009.33 1215.07,-1036.6 1239,-1062 1249.98,-1073.66 1261.59,-1085.63 1273.32,-1097.63"/>
-<text text-anchor="start" x="1242.32" y="-1086.43" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.3" y="-971.37" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.21,-989.73C1196.2,-1017.2 1220.95,-1045.08 1245,-1071 1255.89,-1082.74 1267.44,-1094.78 1279.13,-1106.8"/>
+<text text-anchor="start" x="1248.13" y="-1095.6" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.21" y="-978.53" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge38" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.3,-1000.37C1190.32,-1027.33 1215.07,-1054.6 1239,-1080 1244.56,-1085.9 1250.27,-1091.88 1256.08,-1097.89"/>
-<text text-anchor="start" x="1225.08" y="-1086.69" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.3" y="-989.17" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.21,-1007.54C1196.2,-1035.2 1220.95,-1063.08 1245,-1089 1250.51,-1094.94 1256.19,-1100.96 1261.97,-1107"/>
+<text text-anchor="start" x="1230.97" y="-1095.8" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.21" y="-996.34" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge39" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.3,-1018.17C1190.22,-1045.22 1214.88,-1072.39 1238.72,-1097.7"/>
-<text text-anchor="start" x="1207.72" y="-1101.5" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.3" y="-1006.97" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.21,-1025.35C1196.11,-1053.09 1220.76,-1080.86 1244.72,-1106.7"/>
+<text text-anchor="start" x="1213.72" y="-1110.5" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.21" y="-1014.15" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge40" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.3,-1035.97C1190.22,-1063.22 1214.88,-1090.39 1238.72,-1115.7"/>
-<text text-anchor="start" x="1207.72" y="-1119.5" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.3" y="-1024.77" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.21,-1043.17C1196.11,-1071.09 1220.76,-1098.86 1244.72,-1124.7"/>
+<text text-anchor="start" x="1213.72" y="-1128.5" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.21" y="-1031.97" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_fail -->
<g id="node37" class="node">
<title>task_fail</title>
-<polygon fill="none" stroke="black" points="1267,-386 1267,-414 1523,-414 1523,-386 1267,-386"/>
-<text text-anchor="start" x="1357.5" y="-397.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_fail</text>
-<polygon fill="none" stroke="black" points="1267,-361 1267,-386 1523,-386 1523,-361 1267,-361"/>
-<text text-anchor="start" x="1272" y="-370.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1285" y="-370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1362" y="-370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-336 1267,-361 1523,-361 1523,-336 1267,-336"/>
-<text text-anchor="start" x="1272" y="-345.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1318" y="-345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1439" y="-345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-311 1267,-336 1523,-336 1523,-311 1267,-311"/>
-<text text-anchor="start" x="1272" y="-320.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="1331" y="-320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1267,-286 1267,-311 1523,-311 1523,-286 1267,-286"/>
-<text text-anchor="start" x="1272" y="-295.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1336" y="-295.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1267,-261 1267,-286 1523,-286 1523,-261 1267,-261"/>
-<text text-anchor="start" x="1272" y="-270.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1348" y="-270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1425" y="-270.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-236 1267,-261 1523,-261 1523,-236 1267,-236"/>
-<text text-anchor="start" x="1272" y="-245.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1316" y="-245.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1437" y="-245.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-211 1267,-236 1523,-236 1523,-211 1267,-211"/>
-<text text-anchor="start" x="1272" y="-220.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1342" y="-220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1267,-186 1267,-211 1523,-211 1523,-186 1267,-186"/>
-<text text-anchor="start" x="1272" y="-195.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1321" y="-195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1442" y="-195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-395 1273,-423 1529,-423 1529,-395 1273,-395"/>
+<text text-anchor="start" x="1363.5" y="-406.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_fail</text>
+<polygon fill="none" stroke="black" points="1273,-370 1273,-395 1529,-395 1529,-370 1273,-370"/>
+<text text-anchor="start" x="1278" y="-379.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1291" y="-379.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1368" y="-379.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-345 1273,-370 1529,-370 1529,-345 1273,-345"/>
+<text text-anchor="start" x="1278" y="-354.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1324" y="-354.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1445" y="-354.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-320 1273,-345 1529,-345 1529,-320 1273,-320"/>
+<text text-anchor="start" x="1278" y="-329.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="1337" y="-329.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1273,-295 1273,-320 1529,-320 1529,-295 1273,-295"/>
+<text text-anchor="start" x="1278" y="-304.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1342" y="-304.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1273,-270 1273,-295 1529,-295 1529,-270 1273,-270"/>
+<text text-anchor="start" x="1278" y="-279.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1354" y="-279.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1431" y="-279.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-245 1273,-270 1529,-270 1529,-245 1273,-245"/>
+<text text-anchor="start" x="1278" y="-254.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1322" y="-254.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1443" y="-254.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-220 1273,-245 1529,-245 1529,-220 1273,-220"/>
+<text text-anchor="start" x="1278" y="-229.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1348" y="-229.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1273,-195 1273,-220 1529,-220 1529,-195 1273,-195"/>
+<text text-anchor="start" x="1278" y="-204.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1327" y="-204.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1448" y="-204.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--task_fail -->
<g id="edge29" class="edge">
<title>task_instance--task_fail</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.07,-497.93C1188.81,-463.51 1213.27,-430.13 1239,-400 1245.21,-392.72 1251.88,-385.55 1258.83,-378.56"/>
-<text text-anchor="start" x="1227.83" y="-367.36" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.07" y="-486.73" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.01,-504.4C1194.91,-470.9 1219.42,-438.38 1245,-409 1251.28,-401.78 1258,-394.65 1265,-387.71"/>
+<text text-anchor="start" x="1234" y="-376.51" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.01" y="-493.2" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_fail -->
<g id="edge30" class="edge">
<title>task_instance--task_fail</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.07,-515.79C1188.81,-481.51 1213.27,-448.13 1239,-418 1245.21,-410.72 1251.88,-403.55 1258.83,-396.54"/>
-<text text-anchor="start" x="1227.83" y="-385.34" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.07" y="-504.59" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.01,-522.26C1194.91,-488.9 1219.42,-456.38 1245,-427 1251.28,-419.78 1258,-412.65 1265,-405.68"/>
+<text text-anchor="start" x="1234" y="-394.48" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.01" y="-511.06" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_fail -->
<g id="edge31" class="edge">
<title>task_instance--task_fail</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.07,-533.66C1188.81,-499.51 1213.27,-466.13 1239,-436 1245.21,-428.72 1251.88,-421.55 1258.83,-414.52"/>
-<text text-anchor="start" x="1227.83" y="-403.32" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.07" y="-522.46" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.19,-539.88C1195.03,-506.73 1219.48,-474.31 1245,-445 1251.28,-437.78 1258,-430.65 1265,-423.66"/>
+<text text-anchor="start" x="1234" y="-412.46" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.19" y="-528.68" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_fail -->
<g id="edge32" class="edge">
<title>task_instance--task_fail</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.07,-551.53C1188.81,-517.51 1213.27,-484.13 1239,-454 1249.5,-441.7 1261.31,-429.67 1273.59,-418.07"/>
-<text text-anchor="start" x="1242.59" y="-421.87" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.07" y="-540.33" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.19,-557.75C1195.03,-524.73 1219.48,-492.31 1245,-463 1255.62,-450.8 1267.5,-438.84 1279.82,-427.28"/>
+<text text-anchor="start" x="1248.82" y="-431.08" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.19" y="-546.55" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_map -->
<g id="node38" class="node">
<title>task_map</title>
-<polygon fill="none" stroke="black" points="1267,-1048 1267,-1076 1523,-1076 1523,-1048 1267,-1048"/>
-<text text-anchor="start" x="1352.5" y="-1059.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_map</text>
-<polygon fill="none" stroke="black" points="1267,-1023 1267,-1048 1523,-1048 1523,-1023 1267,-1023"/>
-<text text-anchor="start" x="1272" y="-1032.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1318" y="-1032.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1439" y="-1032.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-998 1267,-1023 1523,-1023 1523,-998 1267,-998"/>
-<text text-anchor="start" x="1272" y="-1007.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1348" y="-1007.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1425" y="-1007.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-973 1267,-998 1523,-998 1523,-973 1267,-973"/>
-<text text-anchor="start" x="1272" y="-982.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1316" y="-982.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1437" y="-982.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-948 1267,-973 1523,-973 1523,-948 1267,-948"/>
-<text text-anchor="start" x="1272" y="-957.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1321" y="-957.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1442" y="-957.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-923 1267,-948 1523,-948 1523,-923 1267,-923"/>
-<text text-anchor="start" x="1272" y="-932.8" font-family="Helvetica,sans-Serif" font-size="14.00">keys</text>
-<text text-anchor="start" x="1304" y="-932.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1267,-898 1267,-923 1523,-923 1523,-898 1267,-898"/>
-<text text-anchor="start" x="1272" y="-907.8" font-family="Helvetica,sans-Serif" font-size="14.00">length</text>
-<text text-anchor="start" x="1317" y="-907.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1394" y="-907.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-1057 1273,-1085 1529,-1085 1529,-1057 1273,-1057"/>
+<text text-anchor="start" x="1358.5" y="-1068.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_map</text>
+<polygon fill="none" stroke="black" points="1273,-1032 1273,-1057 1529,-1057 1529,-1032 1273,-1032"/>
+<text text-anchor="start" x="1278" y="-1041.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1324" y="-1041.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1445" y="-1041.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-1007 1273,-1032 1529,-1032 1529,-1007 1273,-1007"/>
+<text text-anchor="start" x="1278" y="-1016.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1354" y="-1016.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1431" y="-1016.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-982 1273,-1007 1529,-1007 1529,-982 1273,-982"/>
+<text text-anchor="start" x="1278" y="-991.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1322" y="-991.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1443" y="-991.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-957 1273,-982 1529,-982 1529,-957 1273,-957"/>
+<text text-anchor="start" x="1278" y="-966.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1327" y="-966.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1448" y="-966.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-932 1273,-957 1529,-957 1529,-932 1273,-932"/>
+<text text-anchor="start" x="1278" y="-941.8" font-family="Helvetica,sans-Serif" font-size="14.00">keys</text>
+<text text-anchor="start" x="1310" y="-941.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1273,-907 1273,-932 1529,-932 1529,-907 1273,-907"/>
+<text text-anchor="start" x="1278" y="-916.8" font-family="Helvetica,sans-Serif" font-size="14.00">length</text>
+<text text-anchor="start" x="1323" y="-916.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1400" y="-916.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--task_map -->
<g id="edge33" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-870.34C1196.93,-882.9 1228.98,-896.68 1258.97,-910.29"/>
-<text text-anchor="start" x="1248.97" y="-899.09" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-859.14" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-873C1202.87,-886.44 1234.86,-901.1 1264.78,-915.52"/>
+<text text-anchor="start" x="1254.78" y="-904.32" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-861.8" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge34" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-883.64C1196.93,-896.55 1228.98,-910.21 1258.97,-923.23"/>
-<text text-anchor="start" x="1248.97" y="-927.03" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-887.44" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-886.32C1202.87,-900.1 1234.86,-914.62 1264.78,-928.44"/>
+<text text-anchor="start" x="1254.78" y="-932.24" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-890.12" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge35" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-896.95C1196.93,-910.21 1228.98,-923.75 1258.97,-936.17"/>
-<text text-anchor="start" x="1248.97" y="-939.97" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-900.75" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-899.65C1202.87,-913.75 1234.86,-928.14 1264.78,-941.36"/>
+<text text-anchor="start" x="1254.78" y="-945.16" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-903.45" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge36" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-910.25C1196.93,-923.86 1228.98,-937.28 1258.97,-949.11"/>
-<text text-anchor="start" x="1248.97" y="-952.91" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-914.05" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-912.97C1202.87,-927.4 1234.86,-941.66 1264.78,-954.29"/>
+<text text-anchor="start" x="1254.78" y="-958.09" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-916.77" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- xcom -->
<g id="node39" class="node">
<title>xcom</title>
-<polygon fill="none" stroke="black" points="1267,-844 1267,-872 1524,-872 1524,-844 1267,-844"/>
-<text text-anchor="start" x="1371" y="-855.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">xcom</text>
-<polygon fill="none" stroke="black" points="1267,-819 1267,-844 1524,-844 1524,-819 1267,-819"/>
-<text text-anchor="start" x="1272" y="-828.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="1349" y="-828.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1426" y="-828.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-794 1267,-819 1524,-819 1524,-794 1267,-794"/>
-<text text-anchor="start" x="1272" y="-803.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">key</text>
-<text text-anchor="start" x="1297" y="-803.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(512)]</text>
-<text text-anchor="start" x="1418" y="-803.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-769 1267,-794 1524,-794 1524,-769 1267,-769"/>
-<text text-anchor="start" x="1272" y="-778.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1348" y="-778.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1425" y="-778.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-744 1267,-769 1524,-769 1524,-744 1267,-744"/>
-<text text-anchor="start" x="1272" y="-753.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1321" y="-753.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1442" y="-753.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-719 1267,-744 1524,-744 1524,-719 1267,-719"/>
-<text text-anchor="start" x="1272" y="-728.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1318" y="-728.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1439" y="-728.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-694 1267,-719 1524,-719 1524,-694 1267,-694"/>
-<text text-anchor="start" x="1272" y="-703.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1316" y="-703.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1437" y="-703.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-669 1267,-694 1524,-694 1524,-669 1267,-669"/>
-<text text-anchor="start" x="1272" y="-678.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="1347" y="-678.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1443" y="-678.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1267,-644 1267,-669 1524,-669 1524,-644 1267,-644"/>
-<text text-anchor="start" x="1272" y="-653.8" font-family="Helvetica,sans-Serif" font-size="14.00">value</text>
-<text text-anchor="start" x="1310" y="-653.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="1273,-853 1273,-881 1530,-881 1530,-853 1273,-853"/>
+<text text-anchor="start" x="1377" y="-864.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">xcom</text>
+<polygon fill="none" stroke="black" points="1273,-828 1273,-853 1530,-853 1530,-828 1273,-828"/>
+<text text-anchor="start" x="1278" y="-837.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="1355" y="-837.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1432" y="-837.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-803 1273,-828 1530,-828 1530,-803 1273,-803"/>
+<text text-anchor="start" x="1278" y="-812.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">key</text>
+<text text-anchor="start" x="1303" y="-812.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(512)]</text>
+<text text-anchor="start" x="1424" y="-812.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-778 1273,-803 1530,-803 1530,-778 1273,-778"/>
+<text text-anchor="start" x="1278" y="-787.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1354" y="-787.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1431" y="-787.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-753 1273,-778 1530,-778 1530,-753 1273,-753"/>
+<text text-anchor="start" x="1278" y="-762.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1327" y="-762.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1448" y="-762.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-728 1273,-753 1530,-753 1530,-728 1273,-728"/>
+<text text-anchor="start" x="1278" y="-737.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1324" y="-737.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1445" y="-737.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-703 1273,-728 1530,-728 1530,-703 1273,-703"/>
+<text text-anchor="start" x="1278" y="-712.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1322" y="-712.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1443" y="-712.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-678 1273,-703 1530,-703 1530,-678 1273,-678"/>
+<text text-anchor="start" x="1278" y="-687.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="1353" y="-687.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1449" y="-687.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1273,-653 1273,-678 1530,-678 1530,-653 1273,-653"/>
+<text text-anchor="start" x="1278" y="-662.8" font-family="Helvetica,sans-Serif" font-size="14.00">value</text>
+<text text-anchor="start" x="1316" y="-662.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
</g>
<!-- task_instance--xcom -->
<g id="edge41" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-776.37C1196.72,-770.7 1228.55,-765.52 1258.36,-761.38"/>
-<text text-anchor="start" x="1227.36" y="-750.18" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.1" y="-765.17" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-778.04C1202.76,-773.36 1234.65,-769.22 1264.48,-766.05"/>
+<text text-anchor="start" x="1233.48" y="-754.85" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.02" y="-766.84" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge42" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-789.67C1196.72,-784.35 1228.55,-779.06 1258.36,-774.33"/>
-<text text-anchor="start" x="1248.36" y="-778.13" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-793.47" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-791.36C1202.76,-787.01 1234.65,-782.74 1264.48,-778.98"/>
+<text text-anchor="start" x="1254.48" y="-782.78" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-795.16" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge43" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-802.98C1196.72,-798 1228.55,-792.59 1258.36,-787.29"/>
-<text text-anchor="start" x="1248.36" y="-791.09" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.1" y="-806.78" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-804.68C1202.76,-800.66 1234.65,-796.26 1264.48,-791.9"/>
+<text text-anchor="start" x="1233.48" y="-795.7" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1172.02" y="-808.48" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge44" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.1,-816.29C1196.72,-811.66 1228.55,-806.13 1258.36,-800.24"/>
-<text text-anchor="start" x="1227.36" y="-804.04" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1166.1" y="-820.09" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.02,-818.01C1202.76,-814.32 1234.65,-809.78 1264.48,-804.83"/>
+<text text-anchor="start" x="1254.48" y="-808.63" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.02" y="-821.81" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- rendered_task_instance_fields -->
<g id="node40" class="node">
<title>rendered_task_instance_fields</title>
-<polygon fill="none" stroke="black" points="1255,-590 1255,-618 1535,-618 1535,-590 1255,-590"/>
-<text text-anchor="start" x="1260" y="-601.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">rendered_task_instance_fields</text>
-<polygon fill="none" stroke="black" points="1255,-565 1255,-590 1535,-590 1535,-565 1255,-565"/>
-<text text-anchor="start" x="1260" y="-574.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1306" y="-574.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1427" y="-574.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1255,-540 1255,-565 1535,-565 1535,-540 1255,-540"/>
-<text text-anchor="start" x="1260" y="-549.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1336" y="-549.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1413" y="-549.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1255,-515 1255,-540 1535,-540 1535,-515 1255,-515"/>
-<text text-anchor="start" x="1260" y="-524.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1304" y="-524.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1425" y="-524.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1255,-490 1255,-515 1535,-515 1535,-490 1255,-490"/>
-<text text-anchor="start" x="1260" y="-499.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1309" y="-499.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1430" y="-499.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1255,-465 1255,-490 1535,-490 1535,-465 1255,-465"/>
-<text text-anchor="start" x="1260" y="-474.8" font-family="Helvetica,sans-Serif" font-size="14.00">k8s_pod_yaml</text>
-<text text-anchor="start" x="1359" y="-474.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1255,-440 1255,-465 1535,-465 1535,-440 1255,-440"/>
-<text text-anchor="start" x="1260" y="-449.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_fields</text>
-<text text-anchor="start" x="1367" y="-449.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<text text-anchor="start" x="1418" y="-449.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1261,-599 1261,-627 1541,-627 1541,-599 1261,-599"/>
+<text text-anchor="start" x="1266" y="-610.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">rendered_task_instance_fields</text>
+<polygon fill="none" stroke="black" points="1261,-574 1261,-599 1541,-599 1541,-574 1261,-574"/>
+<text text-anchor="start" x="1266" y="-583.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1312" y="-583.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1433" y="-583.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1261,-549 1261,-574 1541,-574 1541,-549 1261,-549"/>
+<text text-anchor="start" x="1266" y="-558.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1342" y="-558.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1419" y="-558.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1261,-524 1261,-549 1541,-549 1541,-524 1261,-524"/>
+<text text-anchor="start" x="1266" y="-533.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1310" y="-533.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1431" y="-533.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1261,-499 1261,-524 1541,-524 1541,-499 1261,-499"/>
+<text text-anchor="start" x="1266" y="-508.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1315" y="-508.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1436" y="-508.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1261,-474 1261,-499 1541,-499 1541,-474 1261,-474"/>
+<text text-anchor="start" x="1266" y="-483.8" font-family="Helvetica,sans-Serif" font-size="14.00">k8s_pod_yaml</text>
+<text text-anchor="start" x="1365" y="-483.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1261,-449 1261,-474 1541,-474 1541,-449 1261,-449"/>
+<text text-anchor="start" x="1266" y="-458.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_fields</text>
+<text text-anchor="start" x="1373" y="-458.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<text text-anchor="start" x="1424" y="-458.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge49" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.31,-660.71C1190.33,-641.05 1215.08,-621.71 1239,-604 1241.59,-602.08 1244.21,-600.16 1246.86,-598.24"/>
-<text text-anchor="start" x="1236.86" y="-587.04" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.31" y="-649.51" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.09,-666.84C1196.32,-648.29 1221.16,-629.96 1245,-613 1247.62,-611.13 1250.28,-609.26 1252.96,-607.37"/>
+<text text-anchor="start" x="1242.96" y="-596.17" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.09" y="-655.64" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge50" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.31,-678.52C1190.33,-659.05 1215.08,-639.71 1239,-622 1241.59,-620.08 1244.21,-618.16 1246.86,-616.24"/>
-<text text-anchor="start" x="1236.86" y="-605.04" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.31" y="-667.32" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.09,-684.64C1196.32,-666.29 1221.16,-647.96 1245,-631 1247.62,-629.13 1250.28,-627.26 1252.96,-625.37"/>
+<text text-anchor="start" x="1242.96" y="-614.17" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.09" y="-673.44" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge51" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.31,-696.32C1190.33,-677.05 1215.08,-657.71 1239,-640 1247.03,-634.06 1255.38,-628.06 1263.87,-622.09"/>
-<text text-anchor="start" x="1253.87" y="-625.89" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.31" y="-685.12" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.09,-702.44C1196.32,-684.29 1221.16,-665.96 1245,-649 1253.27,-643.12 1261.85,-637.14 1270.54,-631.16"/>
+<text text-anchor="start" x="1260.54" y="-634.96" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.09" y="-691.24" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge52" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1166.31,-714.12C1190.33,-695.05 1215.08,-675.71 1239,-658 1255.05,-646.12 1272.42,-634.01 1289.53,-622.09"/>
-<text text-anchor="start" x="1279.53" y="-625.89" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1166.31" y="-702.92" font-family="Times,serif" font-size="14.00">1</text>
-</g>
-<!-- ab_role -->
-<g id="node30" class="node">
-<title>ab_role</title>
-<polygon fill="none" stroke="black" points="496,-2186 496,-2214 734,-2214 734,-2186 496,-2186"/>
-<text text-anchor="start" x="582" y="-2197.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_role</text>
-<polygon fill="none" stroke="black" points="496,-2161 496,-2186 734,-2186 734,-2161 496,-2161"/>
-<text text-anchor="start" x="501" y="-2170.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="514" y="-2170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="591" y="-2170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="496,-2136 496,-2161 734,-2161 734,-2136 496,-2136"/>
-<text text-anchor="start" x="501" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00">name</text>
-<text text-anchor="start" x="541" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(64)]</text>
-<text text-anchor="start" x="653" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-</g>
-<!-- ab_role--ab_user_role -->
-<g id="edge22" class="edge">
-<title>ab_role--ab_user_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M742.13,-2135.43C752.99,-2131.44 763.74,-2127.27 774,-2123 819.91,-2103.88 869.21,-2079.34 910.47,-2057.6"/>
-<text text-anchor="start" x="879.47" y="-2046.4" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="742.13" y="-2124.23" font-family="Times,serif" font-size="14.00">{0,1}</text>
-</g>
-<!-- ab_permission_view_role -->
-<g id="node31" class="node">
-<title>ab_permission_view_role</title>
-<polygon fill="none" stroke="black" points="890.5,-2256 890.5,-2284 1123.5,-2284 1123.5,-2256 890.5,-2256"/>
-<text text-anchor="start" x="895.5" y="-2267.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission_view_role</text>
-<polygon fill="none" stroke="black" points="890.5,-2231 890.5,-2256 1123.5,-2256 1123.5,-2231 890.5,-2231"/>
-<text text-anchor="start" x="895.5" y="-2240.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="908.5" y="-2240.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="985.5" y="-2240.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="890.5,-2206 890.5,-2231 1123.5,-2231 1123.5,-2206 890.5,-2206"/>
-<text text-anchor="start" x="895.5" y="-2215.8" font-family="Helvetica,sans-Serif" font-size="14.00">permission_view_id</text>
-<text text-anchor="start" x="1029.5" y="-2215.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="890.5,-2181 890.5,-2206 1123.5,-2206 1123.5,-2181 890.5,-2181"/>
-<text text-anchor="start" x="895.5" y="-2190.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
-<text text-anchor="start" x="941.5" y="-2190.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-</g>
-<!-- ab_role--ab_permission_view_role -->
-<g id="edge23" class="edge">
-<title>ab_role--ab_permission_view_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M742.19,-2193.79C786.96,-2200.46 837.28,-2207.95 881.84,-2214.59"/>
-<text text-anchor="start" x="850.84" y="-2203.39" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="742.19" y="-2182.59" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1172.09,-720.24C1196.32,-702.29 1221.16,-683.96 1245,-667 1261.54,-655.24 1279.32,-643.08 1296.74,-631.05"/>
+<text text-anchor="start" x="1286.74" y="-634.85" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1172.09" y="-709.04" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- ab_permission -->
-<g id="node32" class="node">
+<g id="node30" class="node">
<title>ab_permission</title>
<polygon fill="none" stroke="black" points="68.5,-2251 68.5,-2279 315.5,-2279 315.5,-2251 68.5,-2251"/>
<text text-anchor="start" x="127" y="-2262.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission</text>
@@ -1479,7 +1441,7 @@
<text text-anchor="start" x="234.5" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- ab_permission_view -->
-<g id="node33" class="node">
+<g id="node31" class="node">
<title>ab_permission_view</title>
<polygon fill="none" stroke="black" points="521,-2315 521,-2343 710,-2343 710,-2315 521,-2315"/>
<text text-anchor="start" x="526" y="-2326.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission_view</text>
@@ -1495,21 +1457,37 @@
<text text-anchor="start" x="624" y="-2249.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_permission--ab_permission_view -->
-<g id="edge24" class="edge">
+<g id="edge22" class="edge">
<title>ab_permission--ab_permission_view</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M323.27,-2256.13C384.18,-2263.65 455.56,-2272.45 512.35,-2279.46"/>
<text text-anchor="start" x="481.35" y="-2268.26" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="323.27" y="-2244.93" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
+<!-- ab_permission_view_role -->
+<g id="node32" class="node">
+<title>ab_permission_view_role</title>
+<polygon fill="none" stroke="black" points="893.5,-2256 893.5,-2284 1126.5,-2284 1126.5,-2256 893.5,-2256"/>
+<text text-anchor="start" x="898.5" y="-2267.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission_view_role</text>
+<polygon fill="none" stroke="black" points="893.5,-2231 893.5,-2256 1126.5,-2256 1126.5,-2231 893.5,-2231"/>
+<text text-anchor="start" x="898.5" y="-2240.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="911.5" y="-2240.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="988.5" y="-2240.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="893.5,-2206 893.5,-2231 1126.5,-2231 1126.5,-2206 893.5,-2206"/>
+<text text-anchor="start" x="898.5" y="-2215.8" font-family="Helvetica,sans-Serif" font-size="14.00">permission_view_id</text>
+<text text-anchor="start" x="1032.5" y="-2215.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="893.5,-2181 893.5,-2206 1126.5,-2206 1126.5,-2181 893.5,-2181"/>
+<text text-anchor="start" x="898.5" y="-2190.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
+<text text-anchor="start" x="944.5" y="-2190.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+</g>
<!-- ab_permission_view--ab_permission_view_role -->
-<g id="edge25" class="edge">
+<g id="edge23" class="edge">
<title>ab_permission_view--ab_permission_view_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M717.57,-2276.61C767.84,-2269 828.94,-2259.74 881.9,-2251.72"/>
-<text text-anchor="start" x="850.9" y="-2240.52" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="717.57" y="-2265.41" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M717.59,-2276.73C768.7,-2269.05 831.06,-2259.67 884.93,-2251.58"/>
+<text text-anchor="start" x="853.93" y="-2240.38" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="717.59" y="-2265.53" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- ab_view_menu -->
-<g id="node34" class="node">
+<g id="node33" class="node">
<title>ab_view_menu</title>
<polygon fill="none" stroke="black" points="68.5,-2355 68.5,-2383 315.5,-2383 315.5,-2355 68.5,-2355"/>
<text text-anchor="start" x="127" y="-2366.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_view_menu</text>
@@ -1523,12 +1501,40 @@
<text text-anchor="start" x="234.5" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- ab_view_menu--ab_permission_view -->
-<g id="edge26" class="edge">
+<g id="edge24" class="edge">
<title>ab_view_menu--ab_permission_view</title>
<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M323.27,-2327.87C384.18,-2320.35 455.56,-2311.55 512.35,-2304.54"/>
<text text-anchor="start" x="481.35" y="-2293.34" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="323.27" y="-2316.67" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
+<!-- ab_role -->
+<g id="node34" class="node">
+<title>ab_role</title>
+<polygon fill="none" stroke="black" points="496,-2186 496,-2214 734,-2214 734,-2186 496,-2186"/>
+<text text-anchor="start" x="582" y="-2197.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_role</text>
+<polygon fill="none" stroke="black" points="496,-2161 496,-2186 734,-2186 734,-2161 496,-2161"/>
+<text text-anchor="start" x="501" y="-2170.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="514" y="-2170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="591" y="-2170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="496,-2136 496,-2161 734,-2161 734,-2136 496,-2136"/>
+<text text-anchor="start" x="501" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00">name</text>
+<text text-anchor="start" x="541" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(64)]</text>
+<text text-anchor="start" x="653" y="-2145.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+</g>
+<!-- ab_role--ab_user_role -->
+<g id="edge25" class="edge">
+<title>ab_role--ab_user_role</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M742.11,-2135.37C752.97,-2131.39 763.73,-2127.25 774,-2123 820.86,-2103.63 871.27,-2078.81 913.31,-2056.93"/>
+<text text-anchor="start" x="882.31" y="-2045.73" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="742.11" y="-2124.17" font-family="Times,serif" font-size="14.00">{0,1}</text>
+</g>
+<!-- ab_role--ab_permission_view_role -->
+<g id="edge26" class="edge">
+<title>ab_role--ab_permission_view_role</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M742.08,-2193.63C787.81,-2200.39 839.39,-2208.01 884.91,-2214.74"/>
+<text text-anchor="start" x="853.91" y="-2203.54" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="742.08" y="-2182.43" font-family="Times,serif" font-size="14.00">{0,1}</text>
+</g>
<!-- dataset_event -->
<g id="node35" class="node">
<title>dataset_event</title>
@@ -1566,9 +1572,9 @@
<!-- dataset_event--dagrun_dataset_event -->
<g id="edge27" class="edge">
<title>dataset_event--dagrun_dataset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M751.68,-1550.43C792.85,-1548.74 837.9,-1546.88 878.48,-1545.22"/>
-<text text-anchor="start" x="868.48" y="-1534.02" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="751.68" y="-1539.23" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M751.63,-1550.47C793.73,-1548.76 839.95,-1546.87 881.45,-1545.18"/>
+<text text-anchor="start" x="871.45" y="-1533.98" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="751.63" y="-1539.27" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- trigger -->
<g id="node36" class="node">
@@ -1598,38 +1604,38 @@
<!-- trigger--task_instance -->
<g id="edge28" class="edge">
<title>trigger--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M764.64,-814.96C791.5,-815.86 819.6,-816.8 846.74,-817.7"/>
-<text text-anchor="start" x="815.74" y="-806.5" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="764.64" y="-803.76" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M764.67,-813.79C791.57,-814.47 819.75,-815.19 847,-815.89"/>
+<text text-anchor="start" x="816" y="-804.69" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="764.67" y="-802.59" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- session -->
<g id="node41" class="node">
<title>session</title>
-<polygon fill="none" stroke="black" points="90.5,-5022 90.5,-5050 293.5,-5050 293.5,-5022 90.5,-5022"/>
-<text text-anchor="start" x="158" y="-5033.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">session</text>
+<polygon fill="none" stroke="black" points="90.5,-5047 90.5,-5075 293.5,-5075 293.5,-5047 90.5,-5047"/>
+<text text-anchor="start" x="158" y="-5058.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">session</text>
+<polygon fill="none" stroke="black" points="90.5,-5022 90.5,-5047 293.5,-5047 293.5,-5022 90.5,-5022"/>
+<text text-anchor="start" x="95.5" y="-5031.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="108.5" y="-5031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="185.5" y="-5031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
<polygon fill="none" stroke="black" points="90.5,-4997 90.5,-5022 293.5,-5022 293.5,-4997 90.5,-4997"/>
-<text text-anchor="start" x="95.5" y="-5006.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="108.5" y="-5006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="185.5" y="-5006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<text text-anchor="start" x="95.5" y="-5006.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
+<text text-anchor="start" x="126.5" y="-5006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
<polygon fill="none" stroke="black" points="90.5,-4972 90.5,-4997 293.5,-4997 293.5,-4972 90.5,-4972"/>
-<text text-anchor="start" x="95.5" y="-4981.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
-<text text-anchor="start" x="126.5" y="-4981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<text text-anchor="start" x="95.5" y="-4981.8" font-family="Helvetica,sans-Serif" font-size="14.00">expiry</text>
+<text text-anchor="start" x="139.5" y="-4981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
<polygon fill="none" stroke="black" points="90.5,-4947 90.5,-4972 293.5,-4972 293.5,-4947 90.5,-4947"/>
-<text text-anchor="start" x="95.5" y="-4956.8" font-family="Helvetica,sans-Serif" font-size="14.00">expiry</text>
-<text text-anchor="start" x="139.5" y="-4956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="90.5,-4922 90.5,-4947 293.5,-4947 293.5,-4922 90.5,-4922"/>
-<text text-anchor="start" x="95.5" y="-4931.8" font-family="Helvetica,sans-Serif" font-size="14.00">session_id</text>
-<text text-anchor="start" x="167.5" y="-4931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(255)]</text>
+<text text-anchor="start" x="95.5" y="-4956.8" font-family="Helvetica,sans-Serif" font-size="14.00">session_id</text>
+<text text-anchor="start" x="167.5" y="-4956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(255)]</text>
</g>
<!-- alembic_version -->
<g id="node42" class="node">
<title>alembic_version</title>
-<polygon fill="none" stroke="black" points="47.5,-5101 47.5,-5129 335.5,-5129 335.5,-5101 47.5,-5101"/>
-<text text-anchor="start" x="119" y="-5112.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">alembic_version</text>
-<polygon fill="none" stroke="black" points="47.5,-5076 47.5,-5101 335.5,-5101 335.5,-5076 47.5,-5076"/>
-<text text-anchor="start" x="52.5" y="-5085.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">version_num</text>
-<text text-anchor="start" x="142.5" y="-5085.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
-<text text-anchor="start" x="254.5" y="-5085.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="47.5,-5126 47.5,-5154 335.5,-5154 335.5,-5126 47.5,-5126"/>
+<text text-anchor="start" x="119" y="-5137.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">alembic_version</text>
+<polygon fill="none" stroke="black" points="47.5,-5101 47.5,-5126 335.5,-5126 335.5,-5101 47.5,-5101"/>
+<text text-anchor="start" x="52.5" y="-5110.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">version_num</text>
+<text text-anchor="start" x="142.5" y="-5110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<text text-anchor="start" x="254.5" y="-5110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
</g>
</svg>
diff --git a/docs/apache-airflow/migrations-ref.rst b/docs/apache-airflow/migrations-ref.rst
index af23ce50ca..44319ce409 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 |
+=================================+===================+===================+==============================================================+
-| ``624ecf3b6a5e`` (head) | ``bd5dfbe21f88`` | ``2.8.0`` | add priority_weight_strategy to task_instance |
+| ``10b52ebd31f7`` (head) | ``624ecf3b6a5e`` | ``2.8.0`` | Add processor_subdir to ImportError. |
++---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
+| ``624ecf3b6a5e`` | ``bd5dfbe21f88`` | ``2.8.0`` | add priority_weight_strategy to task_instance |
+---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
| ``bd5dfbe21f88`` | ``f7bf2a57d0a6`` | ``2.8.0`` | Make connection login/password TEXT |
+---------------------------------+-------------------+-------------------+--------------------------------------------------------------+
diff --git a/tests/dag_processing/test_job_runner.py b/tests/dag_processing/test_job_runner.py
index 8edede91a3..b9bd4d1818 100644
--- a/tests/dag_processing/test_job_runner.py
+++ b/tests/dag_processing/test_job_runner.py
@@ -814,6 +814,68 @@ class TestDagProcessorJobRunner:
with create_session() as session:
assert session.get(DagModel, dag_id) is not None
+ @conf_vars({("core", "load_examples"): "False"})
+ def test_import_error_with_dag_directory(self, tmp_path):
+ TEMP_DAG_FILENAME = "temp_dag.py"
+
+ processor_dir_1 = tmp_path / "processor_1"
+ processor_dir_1.mkdir()
+ filename_1 = os.path.join(processor_dir_1, TEMP_DAG_FILENAME)
+ with open(filename_1, "w") as f:
+ f.write("an invalid airflow DAG")
+
+ processor_dir_2 = tmp_path / "processor_2"
+ processor_dir_2.mkdir()
+ filename_1 = os.path.join(processor_dir_2, TEMP_DAG_FILENAME)
+ with open(filename_1, "w") as f:
+ f.write("an invalid airflow DAG")
+
+ with create_session() as session:
+ child_pipe, parent_pipe = multiprocessing.Pipe()
+
+ manager = DagProcessorJobRunner(
+ job=Job(),
+ processor=DagFileProcessorManager(
+ dag_directory=processor_dir_1,
+ dag_ids=[],
+ max_runs=1,
+ signal_conn=child_pipe,
+ processor_timeout=timedelta(seconds=5),
+ pickle_dags=False,
+ async_mode=False,
+ ),
+ )
+
+ self.run_processor_manager_one_loop(manager, parent_pipe)
+
+ import_errors = session.query(errors.ImportError).order_by("id").all()
+ assert len(import_errors) == 1
+ assert import_errors[0].processor_subdir == str(processor_dir_1)
+
+ child_pipe, parent_pipe = multiprocessing.Pipe()
+
+ manager = DagProcessorJobRunner(
+ job=Job(),
+ processor=DagFileProcessorManager(
+ dag_directory=processor_dir_2,
+ dag_ids=[],
+ max_runs=1,
+ signal_conn=child_pipe,
+ processor_timeout=timedelta(seconds=5),
+ pickle_dags=False,
+ async_mode=True,
+ ),
+ )
+
+ self.run_processor_manager_one_loop(manager, parent_pipe)
+
+ import_errors = session.query(errors.ImportError).order_by("id").all()
+ assert len(import_errors) == 2
+ assert import_errors[0].processor_subdir == str(processor_dir_1)
+ assert import_errors[1].processor_subdir == str(processor_dir_2)
+
+ session.rollback()
+
@conf_vars({("core", "load_examples"): "False"})
@pytest.mark.backend("mysql", "postgres")
@pytest.mark.execution_timeout(30)