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 2024/11/25 18:12:21 UTC
(airflow) branch main updated: Independently update source code changes in DagCode (#44189)
This is an automated email from the ASF dual-hosted git repository.
ephraimanierobi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 2d9e7a51bb3 Independently update source code changes in DagCode (#44189)
2d9e7a51bb3 is described below
commit 2d9e7a51bb30658405e258fdf9e4cfece49b2b71
Author: Ephraim Anierobi <sp...@gmail.com>
AuthorDate: Mon Nov 25 19:12:13 2024 +0100
Independently update source code changes in DagCode (#44189)
* Independently update source code changes in DagCode
When the source code changes but not structural changes that would
trigger a new version, we should update the DagCode's source code.
To do that, I removed the fileloc_hash, which is no longer necessary
as we read the code from the DB. I also added the source_code_hash
column, which is used to detect code changes and update the source code.
* fixup! Independently update source code changes in DagCode
* fixup! fixup! Independently update source code changes in DagCode
* fixup! fixup! fixup! Independently update source code changes in DagCode
* fixup! fixup! fixup! fixup! Independently update source code changes in DagCode
---
.../versions/0047_3_0_0_add_dag_versioning.py | 10 +-
airflow/models/dagbag.py | 4 +
airflow/models/dagcode.py | 114 +-
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 1769 ++++++++++----------
tests/dag_processing/test_job_runner.py | 8 +-
tests/models/test_dagcode.py | 67 +-
tests/models/test_serialized_dag.py | 5 -
8 files changed, 1015 insertions(+), 964 deletions(-)
diff --git a/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py b/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
index e98bf5a2008..5b4bc169751 100644
--- a/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
+++ b/airflow/migrations/versions/0047_3_0_0_add_dag_versioning.py
@@ -80,8 +80,9 @@ def upgrade():
ondelete="CASCADE",
)
batch_op.create_unique_constraint("dag_code_dag_version_id_uq", ["dag_version_id"])
- batch_op.drop_column("last_updated")
- batch_op.add_column(sa.Column("created_at", UtcDateTime(), nullable=False, default=timezone.utcnow))
+ batch_op.add_column(sa.Column("source_code_hash", sa.String(length=32), nullable=False))
+ batch_op.drop_column("fileloc_hash")
+ batch_op.add_column(sa.Column("dag_id", sa.String(length=250), nullable=False))
with op.batch_alter_table(
"serialized_dag", recreate="always", naming_convention=naming_convention
@@ -142,9 +143,10 @@ def downgrade():
batch_op.drop_column("id")
batch_op.drop_constraint(batch_op.f("dag_code_dag_version_id_fkey"), type_="foreignkey")
batch_op.drop_column("dag_version_id")
+ batch_op.add_column(sa.Column("fileloc_hash", sa.BigInteger, nullable=False))
batch_op.create_primary_key("dag_code_pkey", ["fileloc_hash"])
- batch_op.drop_column("created_at")
- batch_op.add_column(sa.Column("last_updated", UtcDateTime(), nullable=False))
+ batch_op.drop_column("source_code_hash")
+ batch_op.drop_column("dag_id")
with op.batch_alter_table("serialized_dag", schema=None, naming_convention=naming_convention) as batch_op:
batch_op.drop_column("id")
diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py
index 5b57c7983ea..1e98e4922e4 100644
--- a/airflow/models/dagbag.py
+++ b/airflow/models/dagbag.py
@@ -50,6 +50,7 @@ from airflow.exceptions import (
)
from airflow.listeners.listener import get_listener_manager
from airflow.models.base import Base
+from airflow.models.dagcode import DagCode
from airflow.stats import Stats
from airflow.utils import timezone
from airflow.utils.dag_cycle_tester import check_cycle
@@ -626,6 +627,9 @@ class DagBag(LoggingMixin):
)
if dag_was_updated:
DagBag._sync_perm_for_dag(dag, session=session)
+ else:
+ # Check and update DagCode
+ DagCode.update_source_code(dag)
return []
except OperationalError:
raise
diff --git a/airflow/models/dagcode.py b/airflow/models/dagcode.py
index e4e364571a7..503aeba2b5e 100644
--- a/airflow/models/dagcode.py
+++ b/airflow/models/dagcode.py
@@ -17,11 +17,10 @@
from __future__ import annotations
import logging
-import struct
from typing import TYPE_CHECKING
import uuid6
-from sqlalchemy import BigInteger, Column, ForeignKey, String, Text, select
+from sqlalchemy import Column, ForeignKey, String, Text, select
from sqlalchemy.dialects.mysql import MEDIUMTEXT
from sqlalchemy.orm import relationship
from sqlalchemy.sql.expression import literal
@@ -29,15 +28,18 @@ from sqlalchemy_utils import UUIDType
from airflow.configuration import conf
from airflow.exceptions import DagCodeNotFound
-from airflow.models.base import Base
+from airflow.models.base import ID_LEN, Base
from airflow.utils import timezone
from airflow.utils.file import open_maybe_zipped
+from airflow.utils.hashlib_wrapper import md5
from airflow.utils.session import NEW_SESSION, provide_session
from airflow.utils.sqlalchemy import UtcDateTime
if TYPE_CHECKING:
from sqlalchemy.orm import Session
+ from sqlalchemy.sql import Select
+ from airflow.models.dag import DAG
from airflow.models.dag_version import DagVersion
log = logging.getLogger(__name__)
@@ -54,11 +56,12 @@ class DagCode(Base):
__tablename__ = "dag_code"
id = Column(UUIDType(binary=False), primary_key=True, default=uuid6.uuid7)
- fileloc_hash = Column(BigInteger, nullable=False)
+ dag_id = Column(String(ID_LEN), nullable=False)
fileloc = Column(String(2000), nullable=False)
# The max length of fileloc exceeds the limit of indexing.
- created_at = Column(UtcDateTime, nullable=False, default=timezone.utcnow)
+ last_updated = Column(UtcDateTime, nullable=False, default=timezone.utcnow, onupdate=timezone.utcnow)
source_code = Column(Text().with_variant(MEDIUMTEXT(), "mysql"), nullable=False)
+ source_code_hash = Column(String(32), nullable=False)
dag_version_id = Column(
UUIDType(binary=False), ForeignKey("dag_version.id", ondelete="CASCADE"), nullable=False, unique=True
)
@@ -67,9 +70,9 @@ class DagCode(Base):
def __init__(self, dag_version, full_filepath: str, source_code: str | None = None):
self.dag_version = dag_version
self.fileloc = full_filepath
- self.fileloc_hash = DagCode.dag_fileloc_hash(self.fileloc)
- self.last_updated = timezone.utcnow()
- self.source_code = source_code or DagCode.code(self.fileloc)
+ self.source_code = source_code or DagCode.code(self.dag_version.dag_id)
+ self.source_code_hash = self.dag_source_hash(self.source_code)
+ self.dag_id = dag_version.dag_id
@classmethod
@provide_session
@@ -81,50 +84,37 @@ class DagCode(Base):
:param session: ORM Session
"""
log.debug("Writing DAG file %s into DagCode table", fileloc)
- dag_code = DagCode(dag_version, fileloc, cls._get_code_from_file(fileloc))
+ dag_code = DagCode(dag_version, fileloc, cls.get_code_from_file(fileloc))
session.add(dag_code)
log.debug("DAG file %s written into DagCode table", fileloc)
return dag_code
@classmethod
@provide_session
- def has_dag(cls, fileloc: str, session: Session = NEW_SESSION) -> bool:
+ def has_dag(cls, dag_id: str, session: Session = NEW_SESSION) -> bool:
"""
- Check a file exist in dag_code table.
+ Check a dag exists in dag code table.
- :param fileloc: the file to check
+ :param dag_id: the dag_id of the DAG
:param session: ORM Session
"""
- fileloc_hash = cls.dag_fileloc_hash(fileloc)
return (
- session.scalars(
- select(literal(True)).where(cls.fileloc_hash == fileloc_hash).limit(1)
- ).one_or_none()
+ session.scalars(select(literal(True)).where(cls.dag_id == dag_id).limit(1)).one_or_none()
is not None
)
- @classmethod
- def get_code_by_fileloc(cls, fileloc: str) -> str:
- """
- Return source code for a given fileloc.
-
- :param fileloc: file path of a DAG
- :return: source code as string
- """
- return cls.code(fileloc)
-
@classmethod
@provide_session
- def code(cls, fileloc, session: Session = NEW_SESSION) -> str:
+ def code(cls, dag_id, session: Session = NEW_SESSION) -> str:
"""
Return source code for this DagCode object.
:return: source code as string
"""
- return cls._get_code_from_db(fileloc, session)
+ return cls._get_code_from_db(dag_id, session)
@staticmethod
- def _get_code_from_file(fileloc):
+ def get_code_from_file(fileloc):
try:
with open_maybe_zipped(fileloc, "r") as f:
code = f.read()
@@ -137,12 +127,9 @@ class DagCode(Base):
@classmethod
@provide_session
- def _get_code_from_db(cls, fileloc, session: Session = NEW_SESSION) -> str:
+ def _get_code_from_db(cls, dag_id, session: Session = NEW_SESSION) -> str:
dag_code = session.scalar(
- select(cls)
- .where(cls.fileloc_hash == cls.dag_fileloc_hash(fileloc))
- .order_by(cls.created_at.desc())
- .limit(1)
+ select(cls).where(cls.dag_id == dag_id).order_by(cls.last_updated.desc()).limit(1)
)
if not dag_code:
raise DagCodeNotFound()
@@ -151,21 +138,52 @@ class DagCode(Base):
return code
@staticmethod
- def dag_fileloc_hash(full_filepath: str) -> int:
+ def dag_source_hash(source: str) -> str:
"""
- Hashing file location for indexing.
+ Hash the source code of the DAG.
- :param full_filepath: full filepath of DAG file
- :return: hashed full_filepath
+ This is needed so we can update the source on code changes
"""
- # Hashing is needed because the length of fileloc is 2000 as an Airflow convention,
- # which is over the limit of indexing.
- import hashlib
+ return md5(source.encode("utf-8")).hexdigest()
- # Only 7 bytes because MySQL BigInteger can hold only 8 bytes (signed).
- return (
- struct.unpack(
- ">Q", hashlib.sha1(full_filepath.encode("utf-8"), usedforsecurity=False).digest()[-8:]
- )[0]
- >> 8
- )
+ @classmethod
+ def _latest_dagcode_select(cls, dag_id: str) -> Select:
+ """
+ Get the select object to get the latest dagcode.
+
+ :param dag_id: The DAG ID.
+ :return: The select object.
+ """
+ return select(cls).where(cls.dag_id == dag_id).order_by(cls.last_updated.desc()).limit(1)
+
+ @classmethod
+ @provide_session
+ def get_latest_dagcode(cls, dag_id: str, session: Session = NEW_SESSION) -> DagCode | None:
+ """
+ Get the latest dagcode.
+
+ :param dag_id: The DAG ID.
+ :param session: The database session.
+ :return: The latest dagcode or None if not found.
+ """
+ return session.scalar(cls._latest_dagcode_select(dag_id))
+
+ @classmethod
+ @provide_session
+ def update_source_code(cls, dag: DAG, session: Session = NEW_SESSION) -> None:
+ """
+ Check if the source code of the DAG has changed and update it if needed.
+
+ :param dag: The DAG object.
+ :param session: The database session.
+ :return: None
+ """
+ latest_dagcode = cls.get_latest_dagcode(dag.dag_id, session)
+ if not latest_dagcode:
+ return
+ new_source_code = cls.get_code_from_file(dag.fileloc)
+ new_source_code_hash = cls.dag_source_hash(new_source_code)
+ if new_source_code_hash != latest_dagcode.source_code_hash:
+ latest_dagcode.source_code = new_source_code
+ latest_dagcode.source_code_hash = new_source_code_hash
+ session.merge(latest_dagcode)
diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256
index 242d0e42204..df1987158fc 100644
--- a/docs/apache-airflow/img/airflow_erd.sha256
+++ b/docs/apache-airflow/img/airflow_erd.sha256
@@ -1 +1 @@
-7748eec981f977cc97b852d1fe982aebe24ec2d090ae8493a65cea101f9d42a5
\ No newline at end of file
+5042271e47bcf1160477200adae4c42ce1cecacf5cbbe7e334d6268debe857fb
\ 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 07796cce6c0..5073c4f273e 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="2030pt" height="4781pt"
- viewBox="0.00 0.00 2030.00 4781.00" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink">
+<svg width="2077pt" height="4781pt"
+ viewBox="0.00 0.00 2077.00 4781.00" 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 4777)">
<title>%3</title>
-<polygon fill="white" stroke="transparent" points="-4,4 -4,-4777 2026,-4777 2026,4 -4,4"/>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-4777 2073,-4777 2073,4 -4,4"/>
<!-- log -->
<g id="node1" class="node">
<title>log</title>
@@ -653,24 +653,24 @@
<!-- dagrun_asset_event -->
<g id="node20" class="node">
<title>dagrun_asset_event</title>
-<polygon fill="none" stroke="black" points="1341,-3926 1341,-3954 1586,-3954 1586,-3926 1341,-3926"/>
-<text text-anchor="start" x="1374" y="-3937.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_asset_event</text>
-<polygon fill="none" stroke="black" points="1341,-3901 1341,-3926 1586,-3926 1586,-3901 1341,-3901"/>
-<text text-anchor="start" x="1346" y="-3910.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="1423" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1428" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1505" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1341,-3876 1341,-3901 1586,-3901 1586,-3876 1341,-3876"/>
-<text text-anchor="start" x="1346" y="-3885.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
-<text text-anchor="start" x="1405" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1410" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1487" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1388,-3926 1388,-3954 1633,-3954 1633,-3926 1388,-3926"/>
+<text text-anchor="start" x="1421" y="-3937.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dagrun_asset_event</text>
+<polygon fill="none" stroke="black" points="1388,-3901 1388,-3926 1633,-3926 1633,-3901 1388,-3901"/>
+<text text-anchor="start" x="1393" y="-3910.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="1470" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1475" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1552" y="-3910.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1388,-3876 1388,-3901 1633,-3901 1633,-3876 1388,-3876"/>
+<text text-anchor="start" x="1393" y="-3885.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">event_id</text>
+<text text-anchor="start" x="1452" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1457" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1534" y="-3885.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- asset_event--dagrun_asset_event -->
<g id="edge12" class="edge">
<title>asset_event--dagrun_asset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M309.61,-3560.11C347,-3608.2 388.19,-3665.46 420,-3721 461.68,-3793.77 425.83,-3844.79 493,-3895 557.65,-3943.33 592.79,-3915 673.5,-3915 673.5,-3915 673.5,-3915 1079.5,-3915 1163.67,-3915 1258.26,-3915 1332.31,-3915"/>
-<text text-anchor="start" x="1301.31" y="-3903.8" font-family="Times,serif" font-size="14.00">0..N</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M309.61,-3560.11C347,-3608.2 388.19,-3665.46 420,-3721 461.68,-3793.77 425.83,-3844.79 493,-3895 557.65,-3943.33 592.79,-3915 673.5,-3915 673.5,-3915 673.5,-3915 1103,-3915 1195.34,-3915 1299.49,-3915 1379.18,-3915"/>
+<text text-anchor="start" x="1348.18" y="-3903.8" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="299.61" y="-3563.91" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- trigger -->
@@ -713,687 +713,687 @@
<!-- task_instance -->
<g id="node22" class="node">
<title>task_instance</title>
-<polygon fill="none" stroke="black" points="1309,-3346 1309,-3374 1617,-3374 1617,-3346 1309,-3346"/>
-<text text-anchor="start" x="1401.5" y="-3357.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
-<polygon fill="none" stroke="black" points="1309,-3321 1309,-3346 1617,-3346 1617,-3321 1309,-3321"/>
-<text text-anchor="start" x="1314" y="-3330.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1327" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1332" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<text text-anchor="start" x="1384" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-3296 1309,-3321 1617,-3321 1617,-3296 1309,-3296"/>
-<text text-anchor="start" x="1314" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
-<text text-anchor="start" x="1477" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1482" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-3271 1309,-3296 1617,-3296 1617,-3271 1309,-3271"/>
-<text text-anchor="start" x="1314" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1360" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1365" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1486" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-3246 1309,-3271 1617,-3271 1617,-3246 1309,-3246"/>
-<text text-anchor="start" x="1314" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
-<text text-anchor="start" x="1418" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1423" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<polygon fill="none" stroke="black" points="1309,-3221 1309,-3246 1617,-3246 1617,-3221 1309,-3221"/>
-<text text-anchor="start" x="1314" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="1373" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1378" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
-<polygon fill="none" stroke="black" points="1309,-3196 1309,-3221 1617,-3221 1617,-3196 1309,-3196"/>
-<text text-anchor="start" x="1314" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1378" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1383" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1309,-3171 1309,-3196 1617,-3196 1617,-3171 1309,-3171"/>
-<text text-anchor="start" x="1314" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor</text>
-<text text-anchor="start" x="1375" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1380" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-3146 1309,-3171 1617,-3171 1617,-3146 1309,-3146"/>
-<text text-anchor="start" x="1314" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
-<text text-anchor="start" x="1424" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1429" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
-<polygon fill="none" stroke="black" points="1309,-3121 1309,-3146 1617,-3146 1617,-3121 1309,-3121"/>
-<text text-anchor="start" x="1314" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
-<text text-anchor="start" x="1457" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1462" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="1309,-3096 1309,-3121 1617,-3121 1617,-3096 1309,-3096"/>
-<text text-anchor="start" x="1314" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
-<text text-anchor="start" x="1384" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1389" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-3071 1309,-3096 1617,-3096 1617,-3071 1309,-3071"/>
-<text text-anchor="start" x="1314" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_heartbeat_at</text>
-<text text-anchor="start" x="1434" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1439" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1309,-3046 1309,-3071 1617,-3071 1617,-3046 1309,-3046"/>
-<text text-anchor="start" x="1314" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1390" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1395" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1472" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-3021 1309,-3046 1617,-3046 1617,-3021 1309,-3021"/>
-<text text-anchor="start" x="1314" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
-<text text-anchor="start" x="1382" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1387" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2996 1309,-3021 1617,-3021 1617,-2996 1309,-2996"/>
-<text text-anchor="start" x="1314" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
-<text text-anchor="start" x="1402" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1407" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1309,-2971 1309,-2996 1617,-2996 1617,-2971 1309,-2971"/>
-<text text-anchor="start" x="1314" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
-<text text-anchor="start" x="1405" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1410" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-2946 1309,-2971 1617,-2971 1617,-2946 1309,-2946"/>
-<text text-anchor="start" x="1314" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
-<text text-anchor="start" x="1374" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1379" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-2921 1309,-2946 1617,-2946 1617,-2921 1309,-2921"/>
-<text text-anchor="start" x="1314" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
-<text text-anchor="start" x="1336" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1341" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2896 1309,-2921 1617,-2921 1617,-2896 1309,-2896"/>
-<text text-anchor="start" x="1314" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
-<text text-anchor="start" x="1344" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1349" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<text text-anchor="start" x="1470" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-2871 1309,-2896 1617,-2896 1617,-2871 1309,-2871"/>
-<text text-anchor="start" x="1314" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
-<text text-anchor="start" x="1383" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1388" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1465" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-2846 1309,-2871 1617,-2871 1617,-2846 1309,-2846"/>
-<text text-anchor="start" x="1314" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
-<text text-anchor="start" x="1418" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1423" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2821 1309,-2846 1617,-2846 1617,-2821 1309,-2821"/>
-<text text-anchor="start" x="1314" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
-<text text-anchor="start" x="1358" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1363" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<polygon fill="none" stroke="black" points="1309,-2796 1309,-2821 1617,-2821 1617,-2796 1309,-2796"/>
-<text text-anchor="start" x="1314" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
-<text text-anchor="start" x="1438" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1443" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2771 1309,-2796 1617,-2796 1617,-2771 1309,-2771"/>
-<text text-anchor="start" x="1314" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
-<text text-anchor="start" x="1407" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1412" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1309,-2746 1309,-2771 1617,-2771 1617,-2746 1309,-2746"/>
-<text text-anchor="start" x="1314" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_map_index</text>
-<text text-anchor="start" x="1459" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1464" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="1309,-2721 1309,-2746 1617,-2746 1617,-2721 1309,-2721"/>
-<text text-anchor="start" x="1314" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1358" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1363" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1484" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-2696 1309,-2721 1617,-2721 1617,-2696 1309,-2696"/>
-<text text-anchor="start" x="1314" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1384" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1389" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1309,-2671 1309,-2696 1617,-2696 1617,-2671 1309,-2671"/>
-<text text-anchor="start" x="1314" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="1349" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1354" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
-<polygon fill="none" stroke="black" points="1309,-2646 1309,-2671 1617,-2671 1617,-2646 1309,-2646"/>
-<text text-anchor="start" x="1314" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_display_name</text>
-<text text-anchor="start" x="1446" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1451" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<polygon fill="none" stroke="black" points="1309,-2621 1309,-2646 1617,-2646 1617,-2621 1309,-2621"/>
-<text text-anchor="start" x="1314" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1363" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1368" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1489" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1309,-2596 1309,-2621 1617,-2621 1617,-2596 1309,-2596"/>
-<text text-anchor="start" x="1314" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
-<text text-anchor="start" x="1381" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1386" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2571 1309,-2596 1617,-2596 1617,-2571 1309,-2571"/>
-<text text-anchor="start" x="1314" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
-<text text-anchor="start" x="1422" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1427" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1309,-2546 1309,-2571 1617,-2571 1617,-2546 1309,-2546"/>
-<text text-anchor="start" x="1314" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="1396" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1401" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1309,-2521 1309,-2546 1617,-2546 1617,-2521 1309,-2521"/>
-<text text-anchor="start" x="1314" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
-<text text-anchor="start" x="1384" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1389" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1309,-2496 1309,-2521 1617,-2521 1617,-2496 1309,-2496"/>
-<text text-anchor="start" x="1314" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1393" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1398" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-3346 1356,-3374 1664,-3374 1664,-3346 1356,-3346"/>
+<text text-anchor="start" x="1448.5" y="-3357.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance</text>
+<polygon fill="none" stroke="black" points="1356,-3321 1356,-3346 1664,-3346 1664,-3321 1356,-3321"/>
+<text text-anchor="start" x="1361" y="-3330.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1374" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1379" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<text text-anchor="start" x="1431" y="-3330.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-3296 1356,-3321 1664,-3321 1664,-3296 1356,-3296"/>
+<text text-anchor="start" x="1361" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
+<text text-anchor="start" x="1524" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1529" y="-3305.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-3271 1356,-3296 1664,-3296 1664,-3271 1356,-3271"/>
+<text text-anchor="start" x="1361" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1407" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1412" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1533" y="-3280.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-3246 1356,-3271 1664,-3271 1664,-3246 1356,-3246"/>
+<text text-anchor="start" x="1361" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
+<text text-anchor="start" x="1465" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1470" y="-3255.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<polygon fill="none" stroke="black" points="1356,-3221 1356,-3246 1664,-3246 1664,-3221 1356,-3221"/>
+<text text-anchor="start" x="1361" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="1420" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1425" y="-3230.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
+<polygon fill="none" stroke="black" points="1356,-3196 1356,-3221 1664,-3221 1664,-3196 1356,-3196"/>
+<text text-anchor="start" x="1361" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1425" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1430" y="-3205.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-3171 1356,-3196 1664,-3196 1664,-3171 1356,-3171"/>
+<text text-anchor="start" x="1361" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor</text>
+<text text-anchor="start" x="1422" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1427" y="-3180.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-3146 1356,-3171 1664,-3171 1664,-3146 1356,-3146"/>
+<text text-anchor="start" x="1361" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
+<text text-anchor="start" x="1471" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1476" y="-3155.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="1356,-3121 1356,-3146 1664,-3146 1664,-3121 1356,-3121"/>
+<text text-anchor="start" x="1361" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
+<text text-anchor="start" x="1504" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1509" y="-3130.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="1356,-3096 1356,-3121 1664,-3121 1664,-3096 1356,-3096"/>
+<text text-anchor="start" x="1361" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
+<text text-anchor="start" x="1431" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1436" y="-3105.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-3071 1356,-3096 1664,-3096 1664,-3071 1356,-3071"/>
+<text text-anchor="start" x="1361" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_heartbeat_at</text>
+<text text-anchor="start" x="1481" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1486" y="-3080.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-3046 1356,-3071 1664,-3071 1664,-3046 1356,-3046"/>
+<text text-anchor="start" x="1361" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1437" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1442" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1519" y="-3055.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-3021 1356,-3046 1664,-3046 1664,-3021 1356,-3021"/>
+<text text-anchor="start" x="1361" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
+<text text-anchor="start" x="1429" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1434" y="-3030.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2996 1356,-3021 1664,-3021 1664,-2996 1356,-2996"/>
+<text text-anchor="start" x="1361" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
+<text text-anchor="start" x="1449" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1454" y="-3005.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1356,-2971 1356,-2996 1664,-2996 1664,-2971 1356,-2971"/>
+<text text-anchor="start" x="1361" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
+<text text-anchor="start" x="1452" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1457" y="-2980.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-2946 1356,-2971 1664,-2971 1664,-2946 1356,-2946"/>
+<text text-anchor="start" x="1361" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
+<text text-anchor="start" x="1421" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1426" y="-2955.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-2921 1356,-2946 1664,-2946 1664,-2921 1356,-2921"/>
+<text text-anchor="start" x="1361" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
+<text text-anchor="start" x="1383" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1388" y="-2930.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2896 1356,-2921 1664,-2921 1664,-2896 1356,-2896"/>
+<text text-anchor="start" x="1361" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
+<text text-anchor="start" x="1391" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1396" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<text text-anchor="start" x="1517" y="-2905.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-2871 1356,-2896 1664,-2896 1664,-2871 1356,-2871"/>
+<text text-anchor="start" x="1361" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
+<text text-anchor="start" x="1430" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1435" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1512" y="-2880.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-2846 1356,-2871 1664,-2871 1664,-2846 1356,-2846"/>
+<text text-anchor="start" x="1361" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
+<text text-anchor="start" x="1465" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1470" y="-2855.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2821 1356,-2846 1664,-2846 1664,-2821 1356,-2821"/>
+<text text-anchor="start" x="1361" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
+<text text-anchor="start" x="1405" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1410" y="-2830.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<polygon fill="none" stroke="black" points="1356,-2796 1356,-2821 1664,-2821 1664,-2796 1356,-2796"/>
+<text text-anchor="start" x="1361" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
+<text text-anchor="start" x="1485" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1490" y="-2805.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2771 1356,-2796 1664,-2796 1664,-2771 1356,-2771"/>
+<text text-anchor="start" x="1361" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
+<text text-anchor="start" x="1454" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1459" y="-2780.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-2746 1356,-2771 1664,-2771 1664,-2746 1356,-2746"/>
+<text text-anchor="start" x="1361" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_map_index</text>
+<text text-anchor="start" x="1506" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1511" y="-2755.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="1356,-2721 1356,-2746 1664,-2746 1664,-2721 1356,-2721"/>
+<text text-anchor="start" x="1361" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1405" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1410" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1531" y="-2730.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-2696 1356,-2721 1664,-2721 1664,-2696 1356,-2696"/>
+<text text-anchor="start" x="1361" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1431" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1436" y="-2705.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-2671 1356,-2696 1664,-2696 1664,-2671 1356,-2671"/>
+<text text-anchor="start" x="1361" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="1396" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1401" y="-2680.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
+<polygon fill="none" stroke="black" points="1356,-2646 1356,-2671 1664,-2671 1664,-2646 1356,-2646"/>
+<text text-anchor="start" x="1361" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_display_name</text>
+<text text-anchor="start" x="1493" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1498" y="-2655.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<polygon fill="none" stroke="black" points="1356,-2621 1356,-2646 1664,-2646 1664,-2621 1356,-2621"/>
+<text text-anchor="start" x="1361" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1410" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1415" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1536" y="-2630.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1356,-2596 1356,-2621 1664,-2621 1664,-2596 1356,-2596"/>
+<text text-anchor="start" x="1361" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
+<text text-anchor="start" x="1428" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1433" y="-2605.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2571 1356,-2596 1664,-2596 1664,-2571 1356,-2571"/>
+<text text-anchor="start" x="1361" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
+<text text-anchor="start" x="1469" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1474" y="-2580.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1356,-2546 1356,-2571 1664,-2571 1664,-2546 1356,-2546"/>
+<text text-anchor="start" x="1361" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="1443" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1448" y="-2555.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1356,-2521 1356,-2546 1664,-2546 1664,-2521 1356,-2521"/>
+<text text-anchor="start" x="1361" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
+<text text-anchor="start" x="1431" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1436" y="-2530.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1356,-2496 1356,-2521 1664,-2521 1664,-2496 1356,-2496"/>
+<text text-anchor="start" x="1361" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1440" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1445" y="-2505.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- trigger--task_instance -->
<g id="edge14" class="edge">
<title>trigger--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M362.12,-3217.59C452.14,-3233.23 568.89,-3249 673.5,-3249 673.5,-3249 673.5,-3249 1079.5,-3249 1163.7,-3249 1239.49,-3202.98 1300.96,-3146.18"/>
-<text text-anchor="start" x="1269.96" y="-3134.98" font-family="Times,serif" font-size="14.00">0..N</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M362.12,-3217.59C452.14,-3233.23 568.89,-3249 673.5,-3249 673.5,-3249 673.5,-3249 1103,-3249 1195.67,-3249 1280.05,-3197.18 1347.59,-3135.64"/>
+<text text-anchor="start" x="1316.59" y="-3124.44" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="362.12" y="-3206.39" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- task_reschedule -->
<g id="node34" class="node">
<title>task_reschedule</title>
-<polygon fill="none" stroke="black" points="1710,-3892 1710,-3920 2011,-3920 2011,-3892 1710,-3892"/>
-<text text-anchor="start" x="1788" y="-3903.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_reschedule</text>
-<polygon fill="none" stroke="black" points="1710,-3867 1710,-3892 2011,-3892 2011,-3867 1710,-3867"/>
-<text text-anchor="start" x="1715" y="-3876.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1728" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1733" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1810" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3842 1710,-3867 2011,-3867 2011,-3842 1710,-3842"/>
-<text text-anchor="start" x="1715" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1761" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1766" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1887" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3817 1710,-3842 2011,-3842 2011,-3817 1710,-3817"/>
-<text text-anchor="start" x="1715" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="1774" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1779" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1856" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3792 1710,-3817 2011,-3817 2011,-3792 1710,-3792"/>
-<text text-anchor="start" x="1715" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1779" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1784" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1880" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3767 1710,-3792 2011,-3792 2011,-3767 1710,-3767"/>
-<text text-anchor="start" x="1715" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1791" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1796" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1873" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3742 1710,-3767 2011,-3767 2011,-3742 1710,-3742"/>
-<text text-anchor="start" x="1715" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00">reschedule_date</text>
-<text text-anchor="start" x="1829" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1834" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1930" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3717 1710,-3742 2011,-3742 2011,-3717 1710,-3717"/>
-<text text-anchor="start" x="1715" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1759" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1764" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1885" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3692 1710,-3717 2011,-3717 2011,-3692 1710,-3692"/>
-<text text-anchor="start" x="1715" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1785" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1790" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1886" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3667 1710,-3692 2011,-3692 2011,-3667 1710,-3667"/>
-<text text-anchor="start" x="1715" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1764" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1769" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1890" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1710,-3642 1710,-3667 2011,-3667 2011,-3642 1710,-3642"/>
-<text text-anchor="start" x="1715" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="1797" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1802" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1879" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3892 1757,-3920 2058,-3920 2058,-3892 1757,-3892"/>
+<text text-anchor="start" x="1835" y="-3903.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_reschedule</text>
+<polygon fill="none" stroke="black" points="1757,-3867 1757,-3892 2058,-3892 2058,-3867 1757,-3867"/>
+<text text-anchor="start" x="1762" y="-3876.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1775" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1780" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1857" y="-3876.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3842 1757,-3867 2058,-3867 2058,-3842 1757,-3842"/>
+<text text-anchor="start" x="1762" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1808" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1813" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1934" y="-3851.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3817 1757,-3842 2058,-3842 2058,-3817 1757,-3817"/>
+<text text-anchor="start" x="1762" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="1821" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1826" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1903" y="-3826.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3792 1757,-3817 2058,-3817 2058,-3792 1757,-3792"/>
+<text text-anchor="start" x="1762" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1826" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1831" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1927" y="-3801.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3767 1757,-3792 2058,-3792 2058,-3767 1757,-3767"/>
+<text text-anchor="start" x="1762" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1838" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1843" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1920" y="-3776.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3742 1757,-3767 2058,-3767 2058,-3742 1757,-3742"/>
+<text text-anchor="start" x="1762" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00">reschedule_date</text>
+<text text-anchor="start" x="1876" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1881" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1977" y="-3751.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3717 1757,-3742 2058,-3742 2058,-3717 1757,-3717"/>
+<text text-anchor="start" x="1762" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1806" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1811" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1932" y="-3726.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3692 1757,-3717 2058,-3717 2058,-3692 1757,-3692"/>
+<text text-anchor="start" x="1762" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1832" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1837" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1933" y="-3701.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3667 1757,-3692 2058,-3692 2058,-3667 1757,-3667"/>
+<text text-anchor="start" x="1762" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1811" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1816" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1937" y="-3676.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1757,-3642 1757,-3667 2058,-3667 2058,-3642 1757,-3642"/>
+<text text-anchor="start" x="1762" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="1844" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1849" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1926" y="-3651.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge45" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1619.78,-3378.18C1660.3,-3497.41 1693.91,-3595.61 1698,-3602 1705.88,-3614.3 1714.97,-3626.3 1724.73,-3637.9"/>
-<text text-anchor="start" x="1724.73" y="-3626.7" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1609.78" y="-3381.98" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1666.78,-3378.18C1707.3,-3497.41 1740.91,-3595.61 1745,-3602 1752.88,-3614.3 1761.97,-3626.3 1771.73,-3637.9"/>
+<text text-anchor="start" x="1771.73" y="-3626.7" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1656.78" y="-3381.98" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge46" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1614,-3378.12C1657.07,-3505.95 1693.71,-3613.31 1698,-3620 1701.84,-3625.99 1705.96,-3631.91 1710.3,-3637.73"/>
-<text text-anchor="start" x="1679.3" y="-3626.53" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1604" y="-3381.92" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1661,-3378.12C1704.07,-3505.95 1740.71,-3613.31 1745,-3620 1748.84,-3625.99 1752.96,-3631.91 1757.3,-3637.73"/>
+<text text-anchor="start" x="1726.3" y="-3626.53" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1651" y="-3381.92" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge47" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1608.32,-3378.02C1653.8,-3514.36 1693.53,-3631.02 1698,-3638 1699.14,-3639.78 1700.31,-3641.55 1701.5,-3643.32"/>
-<text text-anchor="start" x="1670.5" y="-3647.12" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1598.32" y="-3381.82" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1655.32,-3378.02C1700.8,-3514.36 1740.53,-3631.02 1745,-3638 1746.14,-3639.78 1747.31,-3641.55 1748.5,-3643.32"/>
+<text text-anchor="start" x="1717.5" y="-3647.12" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1645.32" y="-3381.82" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_reschedule -->
<g id="edge48" class="edge">
<title>task_instance--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1602.9,-3378.39C1650.61,-3522.97 1693.35,-3648.74 1698,-3656 1699.14,-3657.78 1700.31,-3659.55 1701.5,-3661.32"/>
-<text text-anchor="start" x="1670.5" y="-3665.12" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1592.9" y="-3382.19" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1649.9,-3378.39C1697.61,-3522.97 1740.35,-3648.74 1745,-3656 1746.14,-3657.78 1747.31,-3659.55 1748.5,-3661.32"/>
+<text text-anchor="start" x="1717.5" y="-3665.12" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1639.9" y="-3382.19" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- rendered_task_instance_fields -->
<g id="node36" class="node">
<title>rendered_task_instance_fields</title>
-<polygon fill="none" stroke="black" points="1720,-2455 1720,-2483 2000,-2483 2000,-2455 1720,-2455"/>
-<text text-anchor="start" x="1725" y="-2466.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">rendered_task_instance_fields</text>
-<polygon fill="none" stroke="black" points="1720,-2430 1720,-2455 2000,-2455 2000,-2430 1720,-2430"/>
-<text text-anchor="start" x="1725" y="-2439.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1771" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1776" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1897" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1720,-2405 1720,-2430 2000,-2430 2000,-2405 1720,-2405"/>
-<text text-anchor="start" x="1725" y="-2414.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1801" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1806" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1883" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1720,-2380 1720,-2405 2000,-2405 2000,-2380 1720,-2380"/>
-<text text-anchor="start" x="1725" y="-2389.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1769" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1774" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1895" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1720,-2355 1720,-2380 2000,-2380 2000,-2355 1720,-2355"/>
-<text text-anchor="start" x="1725" y="-2364.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1774" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1779" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1900" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1720,-2330 1720,-2355 2000,-2355 2000,-2330 1720,-2330"/>
-<text text-anchor="start" x="1725" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00">k8s_pod_yaml</text>
-<text text-anchor="start" x="1824" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1829" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1720,-2305 1720,-2330 2000,-2330 2000,-2305 1720,-2305"/>
-<text text-anchor="start" x="1725" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_fields</text>
-<text text-anchor="start" x="1832" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1837" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<text text-anchor="start" x="1888" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1767,-2455 1767,-2483 2047,-2483 2047,-2455 1767,-2455"/>
+<text text-anchor="start" x="1772" y="-2466.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">rendered_task_instance_fields</text>
+<polygon fill="none" stroke="black" points="1767,-2430 1767,-2455 2047,-2455 2047,-2430 1767,-2430"/>
+<text text-anchor="start" x="1772" y="-2439.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1818" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1823" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1944" y="-2439.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1767,-2405 1767,-2430 2047,-2430 2047,-2405 1767,-2405"/>
+<text text-anchor="start" x="1772" y="-2414.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1848" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1853" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1930" y="-2414.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1767,-2380 1767,-2405 2047,-2405 2047,-2380 1767,-2380"/>
+<text text-anchor="start" x="1772" y="-2389.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1816" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1821" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1942" y="-2389.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1767,-2355 1767,-2380 2047,-2380 2047,-2355 1767,-2355"/>
+<text text-anchor="start" x="1772" y="-2364.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1821" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1826" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1947" y="-2364.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1767,-2330 1767,-2355 2047,-2355 2047,-2330 1767,-2330"/>
+<text text-anchor="start" x="1772" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00">k8s_pod_yaml</text>
+<text text-anchor="start" x="1871" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1876" y="-2339.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1767,-2305 1767,-2330 2047,-2330 2047,-2305 1767,-2305"/>
+<text text-anchor="start" x="1772" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_fields</text>
+<text text-anchor="start" x="1879" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1884" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<text text-anchor="start" x="1935" y="-2314.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge37" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.16,-2561.67C1647.31,-2528.21 1671.62,-2496.34 1698,-2468 1702.38,-2463.29 1707.03,-2458.71 1711.89,-2454.29"/>
-<text text-anchor="start" x="1680.89" y="-2443.09" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.16" y="-2550.47" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.16,-2561.67C1694.31,-2528.21 1718.62,-2496.34 1745,-2468 1749.38,-2463.29 1754.03,-2458.71 1758.89,-2454.29"/>
+<text text-anchor="start" x="1727.89" y="-2443.09" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.16" y="-2550.47" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge38" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.16,-2579.57C1647.31,-2546.21 1671.62,-2514.34 1698,-2486 1702.38,-2481.29 1707.03,-2476.71 1711.89,-2472.28"/>
-<text text-anchor="start" x="1680.89" y="-2461.08" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.16" y="-2568.37" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.16,-2579.57C1694.31,-2546.21 1718.62,-2514.34 1745,-2486 1749.38,-2481.29 1754.03,-2476.71 1758.89,-2472.28"/>
+<text text-anchor="start" x="1727.89" y="-2461.08" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.16" y="-2568.37" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge39" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.16,-2597.48C1647.31,-2564.21 1671.62,-2532.34 1698,-2504 1703.4,-2498.2 1709.2,-2492.61 1715.27,-2487.21"/>
-<text text-anchor="start" x="1684.27" y="-2491.01" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.16" y="-2586.28" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.16,-2597.48C1694.31,-2564.21 1718.62,-2532.34 1745,-2504 1750.4,-2498.2 1756.2,-2492.61 1762.27,-2487.21"/>
+<text text-anchor="start" x="1731.27" y="-2491.01" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.16" y="-2586.28" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--rendered_task_instance_fields -->
<g id="edge40" class="edge">
<title>task_instance--rendered_task_instance_fields</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.16,-2615.38C1647.31,-2582.21 1671.62,-2550.34 1698,-2522 1709.69,-2509.44 1723.28,-2497.82 1737.5,-2487.04"/>
-<text text-anchor="start" x="1737.5" y="-2490.84" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.16" y="-2604.18" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.16,-2615.38C1694.31,-2582.21 1718.62,-2550.34 1745,-2522 1756.69,-2509.44 1770.28,-2497.82 1784.5,-2487.04"/>
+<text text-anchor="start" x="1784.5" y="-2490.84" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.16" y="-2604.18" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_map -->
<g id="node37" class="node">
<title>task_map</title>
-<polygon fill="none" stroke="black" points="1730,-2251 1730,-2279 1991,-2279 1991,-2251 1730,-2251"/>
-<text text-anchor="start" x="1818" y="-2262.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_map</text>
-<polygon fill="none" stroke="black" points="1730,-2226 1730,-2251 1991,-2251 1991,-2226 1730,-2226"/>
-<text text-anchor="start" x="1735" y="-2235.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1781" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1786" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1907" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1730,-2201 1730,-2226 1991,-2226 1991,-2201 1730,-2201"/>
-<text text-anchor="start" x="1735" y="-2210.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1811" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1816" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1893" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1730,-2176 1730,-2201 1991,-2201 1991,-2176 1730,-2176"/>
-<text text-anchor="start" x="1735" y="-2185.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1779" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1784" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1905" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1730,-2151 1730,-2176 1991,-2176 1991,-2151 1730,-2151"/>
-<text text-anchor="start" x="1735" y="-2160.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1784" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1789" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1910" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1730,-2126 1730,-2151 1991,-2151 1991,-2126 1730,-2126"/>
-<text text-anchor="start" x="1735" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00">keys</text>
-<text text-anchor="start" x="1767" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1772" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1730,-2101 1730,-2126 1991,-2126 1991,-2101 1730,-2101"/>
-<text text-anchor="start" x="1735" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00">length</text>
-<text text-anchor="start" x="1780" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1785" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1862" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1777,-2251 1777,-2279 2038,-2279 2038,-2251 1777,-2251"/>
+<text text-anchor="start" x="1865" y="-2262.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_map</text>
+<polygon fill="none" stroke="black" points="1777,-2226 1777,-2251 2038,-2251 2038,-2226 1777,-2226"/>
+<text text-anchor="start" x="1782" y="-2235.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1828" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1833" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1954" y="-2235.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1777,-2201 1777,-2226 2038,-2226 2038,-2201 1777,-2201"/>
+<text text-anchor="start" x="1782" y="-2210.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1858" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1863" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1940" y="-2210.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1777,-2176 1777,-2201 2038,-2201 2038,-2176 1777,-2176"/>
+<text text-anchor="start" x="1782" y="-2185.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1826" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1831" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1952" y="-2185.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1777,-2151 1777,-2176 2038,-2176 2038,-2151 1777,-2151"/>
+<text text-anchor="start" x="1782" y="-2160.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1831" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1836" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1957" y="-2160.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1777,-2126 1777,-2151 2038,-2151 2038,-2126 1777,-2126"/>
+<text text-anchor="start" x="1782" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00">keys</text>
+<text text-anchor="start" x="1814" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1819" y="-2135.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1777,-2101 1777,-2126 2038,-2126 2038,-2101 1777,-2101"/>
+<text text-anchor="start" x="1782" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00">length</text>
+<text text-anchor="start" x="1827" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1832" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1909" y="-2110.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- task_instance--task_map -->
<g id="edge41" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1570.29,-2491.59C1602.85,-2410.82 1644.66,-2331.29 1698,-2265 1704.95,-2256.36 1712.84,-2248.24 1721.3,-2240.71"/>
-<text text-anchor="start" x="1690.3" y="-2229.51" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1560.29" y="-2480.39" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1617.29,-2491.59C1649.85,-2410.82 1691.66,-2331.29 1745,-2265 1751.95,-2256.36 1759.84,-2248.24 1768.3,-2240.71"/>
+<text text-anchor="start" x="1737.3" y="-2229.51" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1607.29" y="-2480.39" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge42" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1577.43,-2491.96C1608.89,-2417.51 1648.48,-2344.55 1698,-2283 1704.95,-2274.36 1712.84,-2266.24 1721.3,-2258.67"/>
-<text text-anchor="start" x="1690.3" y="-2247.47" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1577.43" y="-2480.76" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1624.43,-2491.96C1655.89,-2417.51 1695.48,-2344.55 1745,-2283 1751.95,-2274.36 1759.84,-2266.24 1768.3,-2258.67"/>
+<text text-anchor="start" x="1737.3" y="-2247.47" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1624.43" y="-2480.76" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge43" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1585.22,-2491.69C1615.36,-2423.79 1652.48,-2357.57 1698,-2301 1704.95,-2292.36 1712.84,-2284.24 1721.3,-2276.63"/>
-<text text-anchor="start" x="1690.3" y="-2265.43" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1585.22" y="-2480.49" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1632.22,-2491.69C1662.36,-2423.79 1699.48,-2357.57 1745,-2301 1751.95,-2292.36 1759.84,-2284.24 1768.3,-2276.63"/>
+<text text-anchor="start" x="1737.3" y="-2265.43" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1632.22" y="-2480.49" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_map -->
<g id="edge44" class="edge">
<title>task_instance--task_map</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1593.33,-2491.64C1621.95,-2430.22 1656.48,-2370.6 1698,-2319 1708.48,-2305.98 1721.08,-2294.13 1734.57,-2283.28"/>
-<text text-anchor="start" x="1703.57" y="-2287.08" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1593.33" y="-2480.44" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1640.33,-2491.64C1668.95,-2430.22 1703.48,-2370.6 1745,-2319 1755.48,-2305.98 1768.08,-2294.13 1781.57,-2283.28"/>
+<text text-anchor="start" x="1750.57" y="-2287.08" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1640.33" y="-2480.44" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- xcom -->
<g id="node38" class="node">
<title>xcom</title>
-<polygon fill="none" stroke="black" points="1729,-2047 1729,-2075 1991,-2075 1991,-2047 1729,-2047"/>
-<text text-anchor="start" x="1835.5" y="-2058.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">xcom</text>
-<polygon fill="none" stroke="black" points="1729,-2022 1729,-2047 1991,-2047 1991,-2022 1729,-2022"/>
-<text text-anchor="start" x="1734" y="-2031.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="1811" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1816" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1893" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1997 1729,-2022 1991,-2022 1991,-1997 1729,-1997"/>
-<text text-anchor="start" x="1734" y="-2006.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">key</text>
-<text text-anchor="start" x="1759" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1764" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(512)]</text>
-<text text-anchor="start" x="1885" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1972 1729,-1997 1991,-1997 1991,-1972 1729,-1972"/>
-<text text-anchor="start" x="1734" y="-1981.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1810" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1815" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1892" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1947 1729,-1972 1991,-1972 1991,-1947 1729,-1947"/>
-<text text-anchor="start" x="1734" y="-1956.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1783" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1788" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1909" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1922 1729,-1947 1991,-1947 1991,-1922 1729,-1922"/>
-<text text-anchor="start" x="1734" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1780" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1785" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1906" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1897 1729,-1922 1991,-1922 1991,-1897 1729,-1897"/>
-<text text-anchor="start" x="1734" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1778" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1783" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1904" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1872 1729,-1897 1991,-1897 1991,-1872 1729,-1872"/>
-<text text-anchor="start" x="1734" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
-<text text-anchor="start" x="1809" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1814" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1910" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1729,-1847 1729,-1872 1991,-1872 1991,-1847 1729,-1847"/>
-<text text-anchor="start" x="1734" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00">value</text>
-<text text-anchor="start" x="1772" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1777" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1776,-2047 1776,-2075 2038,-2075 2038,-2047 1776,-2047"/>
+<text text-anchor="start" x="1882.5" y="-2058.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">xcom</text>
+<polygon fill="none" stroke="black" points="1776,-2022 1776,-2047 2038,-2047 2038,-2022 1776,-2022"/>
+<text text-anchor="start" x="1781" y="-2031.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="1858" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1863" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1940" y="-2031.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1997 1776,-2022 2038,-2022 2038,-1997 1776,-1997"/>
+<text text-anchor="start" x="1781" y="-2006.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">key</text>
+<text text-anchor="start" x="1806" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1811" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(512)]</text>
+<text text-anchor="start" x="1932" y="-2006.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1972 1776,-1997 2038,-1997 2038,-1972 1776,-1972"/>
+<text text-anchor="start" x="1781" y="-1981.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1857" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1862" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1939" y="-1981.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1947 1776,-1972 2038,-1972 2038,-1947 1776,-1947"/>
+<text text-anchor="start" x="1781" y="-1956.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1830" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1835" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1956" y="-1956.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1922 1776,-1947 2038,-1947 2038,-1922 1776,-1922"/>
+<text text-anchor="start" x="1781" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1827" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1832" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1953" y="-1931.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1897 1776,-1922 2038,-1922 2038,-1897 1776,-1897"/>
+<text text-anchor="start" x="1781" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1825" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1830" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1951" y="-1906.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1872 1776,-1897 2038,-1897 2038,-1872 1776,-1872"/>
+<text text-anchor="start" x="1781" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00">timestamp</text>
+<text text-anchor="start" x="1856" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1861" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1957" y="-1881.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1776,-1847 1776,-1872 2038,-1872 2038,-1847 1776,-1847"/>
+<text text-anchor="start" x="1781" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00">value</text>
+<text text-anchor="start" x="1819" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1824" y="-1856.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
</g>
<!-- task_instance--xcom -->
<g id="edge49" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1524.56,-2491.76C1559.23,-2345.72 1613.44,-2188.32 1698,-2061 1704.7,-2050.92 1712.45,-2041.27 1720.87,-2032.19"/>
-<text text-anchor="start" x="1689.87" y="-2020.99" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1514.56" y="-2480.56" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1571.56,-2491.76C1606.23,-2345.72 1660.44,-2188.32 1745,-2061 1751.7,-2050.92 1759.45,-2041.27 1767.87,-2032.19"/>
+<text text-anchor="start" x="1736.87" y="-2020.99" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1561.56" y="-2480.56" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge50" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1528.67,-2491.81C1563.47,-2351.59 1616.71,-2201.4 1698,-2079 1704.7,-2068.92 1712.45,-2059.27 1720.87,-2050.15"/>
-<text text-anchor="start" x="1689.87" y="-2038.95" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1528.67" y="-2480.61" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1575.67,-2491.81C1610.47,-2351.59 1663.71,-2201.4 1745,-2079 1751.7,-2068.92 1759.45,-2059.27 1767.87,-2050.15"/>
+<text text-anchor="start" x="1736.87" y="-2038.95" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1575.67" y="-2480.61" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge51" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1532.96,-2491.99C1567.8,-2357.55 1619.98,-2214.47 1698,-2097 1704.7,-2086.92 1712.45,-2077.27 1720.87,-2068.11"/>
-<text text-anchor="start" x="1689.87" y="-2056.91" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1522.96" y="-2480.79" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1579.96,-2491.99C1614.8,-2357.55 1666.98,-2214.47 1745,-2097 1751.7,-2086.92 1759.45,-2077.27 1767.87,-2068.11"/>
+<text text-anchor="start" x="1736.87" y="-2056.91" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1569.96" y="-2480.79" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--xcom -->
<g id="edge52" class="edge">
<title>task_instance--xcom</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1537.58,-2491.75C1572.36,-2363.21 1623.36,-2227.39 1698,-2115 1706.37,-2102.4 1716.4,-2090.48 1727.3,-2079.24"/>
-<text text-anchor="start" x="1696.3" y="-2083.04" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1537.58" y="-2480.55" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1584.58,-2491.75C1619.36,-2363.21 1670.36,-2227.39 1745,-2115 1753.37,-2102.4 1763.4,-2090.48 1774.3,-2079.24"/>
+<text text-anchor="start" x="1743.3" y="-2083.04" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1584.58" y="-2480.55" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance_note -->
<g id="node39" class="node">
<title>task_instance_note</title>
-<polygon fill="none" stroke="black" points="1727,-3588 1727,-3616 1993,-3616 1993,-3588 1727,-3588"/>
-<text text-anchor="start" x="1774" y="-3599.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_note</text>
-<polygon fill="none" stroke="black" points="1727,-3563 1727,-3588 1993,-3588 1993,-3563 1727,-3563"/>
-<text text-anchor="start" x="1732" y="-3572.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1778" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1783" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1904" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3538 1727,-3563 1993,-3563 1993,-3538 1727,-3538"/>
-<text text-anchor="start" x="1732" y="-3547.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1808" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1813" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1890" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3513 1727,-3538 1993,-3538 1993,-3513 1727,-3513"/>
-<text text-anchor="start" x="1732" y="-3522.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1776" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1781" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1902" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3488 1727,-3513 1993,-3513 1993,-3488 1727,-3488"/>
-<text text-anchor="start" x="1732" y="-3497.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1781" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1786" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1907" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3463 1727,-3488 1993,-3488 1993,-3463 1727,-3463"/>
-<text text-anchor="start" x="1732" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
-<text text-anchor="start" x="1785" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1790" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1727,-3438 1727,-3463 1993,-3463 1993,-3438 1727,-3438"/>
-<text text-anchor="start" x="1732" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="1805" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1810" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1906" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3413 1727,-3438 1993,-3438 1993,-3413 1727,-3413"/>
-<text text-anchor="start" x="1732" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1811" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1816" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1912" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1727,-3388 1727,-3413 1993,-3413 1993,-3388 1727,-3388"/>
-<text text-anchor="start" x="1732" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="1783" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1788" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(128)]</text>
+<polygon fill="none" stroke="black" points="1774,-3588 1774,-3616 2040,-3616 2040,-3588 1774,-3588"/>
+<text text-anchor="start" x="1821" y="-3599.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_note</text>
+<polygon fill="none" stroke="black" points="1774,-3563 1774,-3588 2040,-3588 2040,-3563 1774,-3563"/>
+<text text-anchor="start" x="1779" y="-3572.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1825" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1830" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1951" y="-3572.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3538 1774,-3563 2040,-3563 2040,-3538 1774,-3538"/>
+<text text-anchor="start" x="1779" y="-3547.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1855" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1860" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1937" y="-3547.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3513 1774,-3538 2040,-3538 2040,-3513 1774,-3513"/>
+<text text-anchor="start" x="1779" y="-3522.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1823" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1828" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1949" y="-3522.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3488 1774,-3513 2040,-3513 2040,-3488 1774,-3488"/>
+<text text-anchor="start" x="1779" y="-3497.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1828" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1833" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1954" y="-3497.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3463 1774,-3488 2040,-3488 2040,-3463 1774,-3463"/>
+<text text-anchor="start" x="1779" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
+<text text-anchor="start" x="1832" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1837" y="-3472.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1774,-3438 1774,-3463 2040,-3463 2040,-3438 1774,-3438"/>
+<text text-anchor="start" x="1779" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="1852" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1857" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1953" y="-3447.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3413 1774,-3438 2040,-3438 2040,-3413 1774,-3413"/>
+<text text-anchor="start" x="1779" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1858" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1863" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1959" y="-3422.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1774,-3388 1774,-3413 2040,-3413 2040,-3388 1774,-3388"/>
+<text text-anchor="start" x="1779" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="1830" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1835" y="-3397.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(128)]</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge53" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.11,-3245.55C1647.57,-3281.09 1671.95,-3315.72 1698,-3347 1708.63,-3359.76 1720.7,-3372.11 1733.35,-3383.93"/>
-<text text-anchor="start" x="1702.35" y="-3372.73" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.11" y="-3234.35" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.11,-3245.55C1694.57,-3281.09 1718.95,-3315.72 1745,-3347 1755.63,-3359.76 1767.7,-3372.11 1780.35,-3383.93"/>
+<text text-anchor="start" x="1749.35" y="-3372.73" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.11" y="-3234.35" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge54" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.11,-3263.44C1647.57,-3299.09 1671.95,-3333.72 1698,-3365 1704.51,-3372.82 1711.57,-3380.49 1718.97,-3387.95"/>
-<text text-anchor="start" x="1687.97" y="-3391.75" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.11" y="-3252.24" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.11,-3263.44C1694.57,-3299.09 1718.95,-3333.72 1745,-3365 1751.51,-3372.82 1758.57,-3380.49 1765.97,-3387.95"/>
+<text text-anchor="start" x="1734.97" y="-3391.75" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.11" y="-3252.24" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge55" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.11,-3281.33C1647.57,-3317.09 1671.95,-3351.72 1698,-3383 1704.51,-3390.82 1711.57,-3398.49 1718.97,-3405.92"/>
-<text text-anchor="start" x="1687.97" y="-3409.72" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.11" y="-3270.13" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.11,-3281.33C1694.57,-3317.09 1718.95,-3351.72 1745,-3383 1751.51,-3390.82 1758.57,-3398.49 1765.97,-3405.92"/>
+<text text-anchor="start" x="1734.97" y="-3409.72" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.11" y="-3270.13" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_note -->
<g id="edge56" class="edge">
<title>task_instance--task_instance_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.11,-3299.22C1647.57,-3335.09 1671.95,-3369.72 1698,-3401 1704.51,-3408.82 1711.57,-3416.49 1718.97,-3423.9"/>
-<text text-anchor="start" x="1687.97" y="-3427.7" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.11" y="-3288.02" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.11,-3299.22C1694.57,-3335.09 1718.95,-3369.72 1745,-3401 1751.51,-3408.82 1758.57,-3416.49 1765.97,-3423.9"/>
+<text text-anchor="start" x="1734.97" y="-3427.7" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.11" y="-3288.02" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance_history -->
<g id="node40" class="node">
<title>task_instance_history</title>
-<polygon fill="none" stroke="black" points="1706,-3333 1706,-3361 2014,-3361 2014,-3333 1706,-3333"/>
-<text text-anchor="start" x="1762.5" y="-3344.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_history</text>
-<polygon fill="none" stroke="black" points="1706,-3308 1706,-3333 2014,-3333 2014,-3308 1706,-3308"/>
-<text text-anchor="start" x="1711" y="-3317.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1724" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1729" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1806" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-3283 1706,-3308 2014,-3308 2014,-3283 1706,-3283"/>
-<text text-anchor="start" x="1711" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
-<text text-anchor="start" x="1874" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1879" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-3258 1706,-3283 2014,-3283 2014,-3258 1706,-3258"/>
-<text text-anchor="start" x="1711" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="1757" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1762" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1883" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-3233 1706,-3258 2014,-3258 2014,-3233 1706,-3233"/>
-<text text-anchor="start" x="1711" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
-<text text-anchor="start" x="1815" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1820" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<polygon fill="none" stroke="black" points="1706,-3208 1706,-3233 2014,-3233 2014,-3208 1706,-3208"/>
-<text text-anchor="start" x="1711" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
-<text text-anchor="start" x="1770" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1775" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
-<polygon fill="none" stroke="black" points="1706,-3183 1706,-3208 2014,-3208 2014,-3183 1706,-3183"/>
-<text text-anchor="start" x="1711" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1775" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1780" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1706,-3158 1706,-3183 2014,-3183 2014,-3158 1706,-3158"/>
-<text text-anchor="start" x="1711" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor</text>
-<text text-anchor="start" x="1772" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1777" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-3133 1706,-3158 2014,-3158 2014,-3133 1706,-3133"/>
-<text text-anchor="start" x="1711" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
-<text text-anchor="start" x="1821" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1826" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
-<polygon fill="none" stroke="black" points="1706,-3108 1706,-3133 2014,-3133 2014,-3108 1706,-3108"/>
-<text text-anchor="start" x="1711" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
-<text text-anchor="start" x="1854" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1859" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="1706,-3083 1706,-3108 2014,-3108 2014,-3083 1706,-3083"/>
-<text text-anchor="start" x="1711" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
-<text text-anchor="start" x="1781" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1786" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-3058 1706,-3083 2014,-3083 2014,-3058 1706,-3058"/>
-<text text-anchor="start" x="1711" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
-<text text-anchor="start" x="1787" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1792" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1869" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-3033 1706,-3058 2014,-3058 2014,-3033 1706,-3033"/>
-<text text-anchor="start" x="1711" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
-<text text-anchor="start" x="1779" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1784" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1706,-3008 1706,-3033 2014,-3033 2014,-3008 1706,-3008"/>
-<text text-anchor="start" x="1711" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
-<text text-anchor="start" x="1799" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1804" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="1706,-2983 1706,-3008 2014,-3008 2014,-2983 1706,-2983"/>
-<text text-anchor="start" x="1711" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
-<text text-anchor="start" x="1802" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1807" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-2958 1706,-2983 2014,-2983 2014,-2958 1706,-2958"/>
-<text text-anchor="start" x="1711" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
-<text text-anchor="start" x="1771" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1776" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-2933 1706,-2958 2014,-2958 2014,-2933 1706,-2933"/>
-<text text-anchor="start" x="1711" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
-<text text-anchor="start" x="1733" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1738" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1706,-2908 1706,-2933 2014,-2933 2014,-2908 1706,-2908"/>
-<text text-anchor="start" x="1711" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
-<text text-anchor="start" x="1741" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1746" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<text text-anchor="start" x="1867" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-2883 1706,-2908 2014,-2908 2014,-2883 1706,-2883"/>
-<text text-anchor="start" x="1711" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
-<text text-anchor="start" x="1780" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1785" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1862" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-2858 1706,-2883 2014,-2883 2014,-2858 1706,-2858"/>
-<text text-anchor="start" x="1711" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
-<text text-anchor="start" x="1815" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1820" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1706,-2833 1706,-2858 2014,-2858 2014,-2833 1706,-2833"/>
-<text text-anchor="start" x="1711" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
-<text text-anchor="start" x="1755" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1760" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
-<polygon fill="none" stroke="black" points="1706,-2808 1706,-2833 2014,-2833 2014,-2808 1706,-2808"/>
-<text text-anchor="start" x="1711" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
-<text text-anchor="start" x="1835" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1840" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1706,-2783 1706,-2808 2014,-2808 2014,-2783 1706,-2783"/>
-<text text-anchor="start" x="1711" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
-<text text-anchor="start" x="1804" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1809" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1706,-2758 1706,-2783 2014,-2783 2014,-2758 1706,-2758"/>
-<text text-anchor="start" x="1711" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_map_index</text>
-<text text-anchor="start" x="1856" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1861" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="1706,-2733 1706,-2758 2014,-2758 2014,-2733 1706,-2733"/>
-<text text-anchor="start" x="1711" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="1755" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1760" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1881" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-2708 1706,-2733 2014,-2733 2014,-2708 1706,-2708"/>
-<text text-anchor="start" x="1711" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1781" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1786" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1706,-2683 1706,-2708 2014,-2708 2014,-2683 1706,-2683"/>
-<text text-anchor="start" x="1711" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="1746" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1751" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
-<polygon fill="none" stroke="black" points="1706,-2658 1706,-2683 2014,-2683 2014,-2658 1706,-2658"/>
-<text text-anchor="start" x="1711" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_display_name</text>
-<text text-anchor="start" x="1843" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1848" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<polygon fill="none" stroke="black" points="1706,-2633 1706,-2658 2014,-2658 2014,-2633 1706,-2633"/>
-<text text-anchor="start" x="1711" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
-<text text-anchor="start" x="1760" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1765" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1886" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-2608 1706,-2633 2014,-2633 2014,-2608 1706,-2608"/>
-<text text-anchor="start" x="1711" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
-<text text-anchor="start" x="1778" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1783" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1706,-2583 1706,-2608 2014,-2608 2014,-2583 1706,-2583"/>
-<text text-anchor="start" x="1711" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
-<text text-anchor="start" x="1819" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1824" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="1706,-2558 1706,-2583 2014,-2583 2014,-2558 1706,-2558"/>
-<text text-anchor="start" x="1711" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
-<text text-anchor="start" x="1793" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1798" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1875" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1706,-2533 1706,-2558 2014,-2558 2014,-2533 1706,-2533"/>
-<text text-anchor="start" x="1711" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
-<text text-anchor="start" x="1781" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1786" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1706,-2508 1706,-2533 2014,-2533 2014,-2508 1706,-2508"/>
-<text text-anchor="start" x="1711" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1790" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1795" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1753,-3333 1753,-3361 2061,-3361 2061,-3333 1753,-3333"/>
+<text text-anchor="start" x="1809.5" y="-3344.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">task_instance_history</text>
+<polygon fill="none" stroke="black" points="1753,-3308 1753,-3333 2061,-3333 2061,-3308 1753,-3308"/>
+<text text-anchor="start" x="1758" y="-3317.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1771" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1776" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1853" y="-3317.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-3283 1753,-3308 2061,-3308 2061,-3283 1753,-3283"/>
+<text text-anchor="start" x="1758" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00">custom_operator_name</text>
+<text text-anchor="start" x="1921" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1926" y="-3292.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-3258 1753,-3283 2061,-3283 2061,-3258 1753,-3258"/>
+<text text-anchor="start" x="1758" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1804" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1809" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1930" y="-3267.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-3233 1753,-3258 2061,-3258 2061,-3233 1753,-3233"/>
+<text text-anchor="start" x="1758" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
+<text text-anchor="start" x="1862" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1867" y="-3242.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<polygon fill="none" stroke="black" points="1753,-3208 1753,-3233 2061,-3233 2061,-3208 1753,-3208"/>
+<text text-anchor="start" x="1758" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00">duration</text>
+<text text-anchor="start" x="1817" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1822" y="-3217.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [DOUBLE_PRECISION]</text>
+<polygon fill="none" stroke="black" points="1753,-3183 1753,-3208 2061,-3208 2061,-3183 1753,-3183"/>
+<text text-anchor="start" x="1758" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1822" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1827" y="-3192.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1753,-3158 1753,-3183 2061,-3183 2061,-3158 1753,-3158"/>
+<text text-anchor="start" x="1758" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor</text>
+<text text-anchor="start" x="1819" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1824" y="-3167.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-3133 1753,-3158 2061,-3158 2061,-3133 1753,-3133"/>
+<text text-anchor="start" x="1758" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00">executor_config</text>
+<text text-anchor="start" x="1868" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1873" y="-3142.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="1753,-3108 1753,-3133 2061,-3133 2061,-3108 1753,-3108"/>
+<text text-anchor="start" x="1758" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_executor_id</text>
+<text text-anchor="start" x="1901" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1906" y="-3117.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="1753,-3083 1753,-3108 2061,-3108 2061,-3083 1753,-3083"/>
+<text text-anchor="start" x="1758" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00">hostname</text>
+<text text-anchor="start" x="1828" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1833" y="-3092.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-3058 1753,-3083 2061,-3083 2061,-3058 1753,-3058"/>
+<text text-anchor="start" x="1758" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00">map_index</text>
+<text text-anchor="start" x="1834" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1839" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1916" y="-3067.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-3033 1753,-3058 2061,-3058 2061,-3033 1753,-3033"/>
+<text text-anchor="start" x="1758" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00">max_tries</text>
+<text text-anchor="start" x="1826" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1831" y="-3042.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1753,-3008 1753,-3033 2061,-3033 2061,-3008 1753,-3008"/>
+<text text-anchor="start" x="1758" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_kwargs</text>
+<text text-anchor="start" x="1846" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1851" y="-3017.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="1753,-2983 1753,-3008 2061,-3008 2061,-2983 1753,-2983"/>
+<text text-anchor="start" x="1758" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00">next_method</text>
+<text text-anchor="start" x="1849" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1854" y="-2992.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-2958 1753,-2983 2061,-2983 2061,-2958 1753,-2958"/>
+<text text-anchor="start" x="1758" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00">operator</text>
+<text text-anchor="start" x="1818" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1823" y="-2967.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-2933 1753,-2958 2061,-2958 2061,-2933 1753,-2933"/>
+<text text-anchor="start" x="1758" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00">pid</text>
+<text text-anchor="start" x="1780" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1785" y="-2942.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1753,-2908 1753,-2933 2061,-2933 2061,-2908 1753,-2908"/>
+<text text-anchor="start" x="1758" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool</text>
+<text text-anchor="start" x="1788" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1793" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<text text-anchor="start" x="1914" y="-2917.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-2883 1753,-2908 2061,-2908 2061,-2883 1753,-2883"/>
+<text text-anchor="start" x="1758" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00">pool_slots</text>
+<text text-anchor="start" x="1827" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1832" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1909" y="-2892.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-2858 1753,-2883 2061,-2883 2061,-2858 1753,-2858"/>
+<text text-anchor="start" x="1758" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00">priority_weight</text>
+<text text-anchor="start" x="1862" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1867" y="-2867.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1753,-2833 1753,-2858 2061,-2858 2061,-2833 1753,-2833"/>
+<text text-anchor="start" x="1758" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00">queue</text>
+<text text-anchor="start" x="1802" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1807" y="-2842.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(256)]</text>
+<polygon fill="none" stroke="black" points="1753,-2808 1753,-2833 2061,-2833 2061,-2808 1753,-2808"/>
+<text text-anchor="start" x="1758" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_by_job_id</text>
+<text text-anchor="start" x="1882" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1887" y="-2817.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1753,-2783 1753,-2808 2061,-2808 2061,-2783 1753,-2783"/>
+<text text-anchor="start" x="1758" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_dttm</text>
+<text text-anchor="start" x="1851" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1856" y="-2792.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1753,-2758 1753,-2783 2061,-2783 2061,-2758 1753,-2758"/>
+<text text-anchor="start" x="1758" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00">rendered_map_index</text>
+<text text-anchor="start" x="1903" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1908" y="-2767.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="1753,-2733 1753,-2758 2061,-2758 2061,-2733 1753,-2733"/>
+<text text-anchor="start" x="1758" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1802" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1807" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1928" y="-2742.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-2708 1753,-2733 2061,-2733 2061,-2708 1753,-2708"/>
+<text text-anchor="start" x="1758" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1828" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1833" y="-2717.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1753,-2683 1753,-2708 2061,-2708 2061,-2683 1753,-2683"/>
+<text text-anchor="start" x="1758" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="1793" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1798" y="-2692.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(20)]</text>
+<polygon fill="none" stroke="black" points="1753,-2658 1753,-2683 2061,-2683 2061,-2658 1753,-2658"/>
+<text text-anchor="start" x="1758" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_display_name</text>
+<text text-anchor="start" x="1890" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1895" y="-2667.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<polygon fill="none" stroke="black" points="1753,-2633 1753,-2658 2061,-2658 2061,-2633 1753,-2633"/>
+<text text-anchor="start" x="1758" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00">task_id</text>
+<text text-anchor="start" x="1807" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1812" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1933" y="-2642.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-2608 1753,-2633 2061,-2633 2061,-2608 1753,-2608"/>
+<text text-anchor="start" x="1758" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_id</text>
+<text text-anchor="start" x="1825" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1830" y="-2617.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1753,-2583 1753,-2608 2061,-2608 2061,-2583 1753,-2583"/>
+<text text-anchor="start" x="1758" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00">trigger_timeout</text>
+<text text-anchor="start" x="1866" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1871" y="-2592.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="1753,-2558 1753,-2583 2061,-2583 2061,-2558 1753,-2558"/>
+<text text-anchor="start" x="1758" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00">try_number</text>
+<text text-anchor="start" x="1840" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1845" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1922" y="-2567.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1753,-2533 1753,-2558 2061,-2558 2061,-2533 1753,-2533"/>
+<text text-anchor="start" x="1758" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00">unixname</text>
+<text text-anchor="start" x="1828" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1833" y="-2542.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1753,-2508 1753,-2533 2061,-2533 2061,-2508 1753,-2508"/>
+<text text-anchor="start" x="1758" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1837" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1842" y="-2517.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
<!-- task_instance--task_instance_history -->
<g id="edge57" class="edge">
<title>task_instance--task_instance_history</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.23,-2915.06C1649.23,-2914.65 1673.97,-2914.65 1697.96,-2915.06"/>
-<text text-anchor="start" x="1666.96" y="-2903.86" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.23" y="-2903.86" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.23,-2915.06C1696.23,-2914.65 1720.97,-2914.65 1744.96,-2915.06"/>
+<text text-anchor="start" x="1713.96" y="-2903.86" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.23" y="-2903.86" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_history -->
<g id="edge58" class="edge">
<title>task_instance--task_instance_history</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.23,-2928.35C1649.23,-2928.22 1673.97,-2928.22 1697.96,-2928.35"/>
-<text text-anchor="start" x="1666.96" y="-2932.15" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.23" y="-2932.15" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.23,-2928.35C1696.23,-2928.22 1720.97,-2928.22 1744.96,-2928.35"/>
+<text text-anchor="start" x="1713.96" y="-2932.15" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.23" y="-2932.15" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_history -->
<g id="edge59" class="edge">
<title>task_instance--task_instance_history</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.23,-2941.65C1649.23,-2941.78 1673.97,-2941.78 1697.96,-2941.65"/>
-<text text-anchor="start" x="1666.96" y="-2945.45" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.23" y="-2945.45" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.23,-2941.65C1696.23,-2941.78 1720.97,-2941.78 1744.96,-2941.65"/>
+<text text-anchor="start" x="1713.96" y="-2945.45" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.23" y="-2945.45" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- task_instance--task_instance_history -->
<g id="edge60" class="edge">
<title>task_instance--task_instance_history</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1625.23,-2954.94C1649.23,-2955.35 1673.97,-2955.35 1697.96,-2954.94"/>
-<text text-anchor="start" x="1666.96" y="-2958.74" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1625.23" y="-2958.74" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1672.23,-2954.94C1696.23,-2955.35 1720.97,-2955.35 1744.96,-2954.94"/>
+<text text-anchor="start" x="1713.96" y="-2958.74" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1672.23" y="-2958.74" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag -->
<g id="node23" class="node">
@@ -1645,317 +1645,322 @@
<!-- dag_version--task_instance -->
<g id="edge26" class="edge">
<title>dag_version--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.24,-1914.45C835,-1921.71 846.12,-1929.86 856,-1939 907.5,-1986.66 894.21,-2018.06 929,-2079 1048.03,-2287.47 1192.47,-2518.21 1300.94,-2687.55"/>
-<text text-anchor="start" x="1269.94" y="-2676.35" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="823.24" y="-1918.25" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.27,-1913.67C835.09,-1921.1 846.22,-1929.51 856,-1939 911.5,-1992.88 890.62,-2029.84 929,-2097 1056.17,-2319.56 1225.16,-2558.6 1347.9,-2724.19"/>
+<text text-anchor="start" x="1316.9" y="-2712.99" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="823.27" y="-1917.47" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
-<!-- dag_run -->
+<!-- dag_code -->
<g id="node28" class="node">
-<title>dag_run</title>
-<polygon fill="none" stroke="black" points="937.5,-3806 937.5,-3834 1220.5,-3834 1220.5,-3806 937.5,-3806"/>
-<text text-anchor="start" x="1042.5" y="-3817.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run</text>
-<polygon fill="none" stroke="black" points="937.5,-3781 937.5,-3806 1220.5,-3806 1220.5,-3781 937.5,-3781"/>
-<text text-anchor="start" x="942.5" y="-3790.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="955.5" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="960.5" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1037.5" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3756 937.5,-3781 1220.5,-3781 1220.5,-3756 937.5,-3756"/>
-<text text-anchor="start" x="942.5" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00">backfill_id</text>
-<text text-anchor="start" x="1012.5" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1017.5" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="937.5,-3731 937.5,-3756 1220.5,-3756 1220.5,-3731 937.5,-3731"/>
-<text text-anchor="start" x="942.5" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00">clear_number</text>
-<text text-anchor="start" x="1038.5" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1043.5" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1120.5" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3706 937.5,-3731 1220.5,-3731 1220.5,-3706 937.5,-3706"/>
-<text text-anchor="start" x="942.5" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00">conf</text>
-<text text-anchor="start" x="973.5" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="978.5" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
-<polygon fill="none" stroke="black" points="937.5,-3681 937.5,-3706 1220.5,-3706 1220.5,-3681 937.5,-3681"/>
-<text text-anchor="start" x="942.5" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00">creating_job_id</text>
-<text text-anchor="start" x="1046.5" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1051.5" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="937.5,-3656 937.5,-3681 1220.5,-3681 1220.5,-3656 937.5,-3656"/>
-<text text-anchor="start" x="942.5" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="988.5" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="993.5" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1114.5" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3631 937.5,-3656 1220.5,-3656 1220.5,-3631 937.5,-3631"/>
-<text text-anchor="start" x="942.5" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
-<text text-anchor="start" x="1046.5" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1051.5" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<polygon fill="none" stroke="black" points="937.5,-3606 937.5,-3631 1220.5,-3631 1220.5,-3606 937.5,-3606"/>
-<text text-anchor="start" x="942.5" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_end</text>
-<text text-anchor="start" x="1066.5" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1071.5" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3581 937.5,-3606 1220.5,-3606 1220.5,-3581 937.5,-3581"/>
-<text text-anchor="start" x="942.5" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_start</text>
-<text text-anchor="start" x="1072.5" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1077.5" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3556 937.5,-3581 1220.5,-3581 1220.5,-3556 937.5,-3556"/>
-<text text-anchor="start" x="942.5" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
-<text text-anchor="start" x="1006.5" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1011.5" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3531 937.5,-3556 1220.5,-3556 1220.5,-3531 937.5,-3531"/>
-<text text-anchor="start" x="942.5" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_trigger</text>
-<text text-anchor="start" x="1053.5" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1058.5" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
-<polygon fill="none" stroke="black" points="937.5,-3506 937.5,-3531 1220.5,-3531 1220.5,-3506 937.5,-3506"/>
-<text text-anchor="start" x="942.5" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_scheduling_decision</text>
-<text text-anchor="start" x="1114.5" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1119.5" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3481 937.5,-3506 1220.5,-3506 1220.5,-3481 937.5,-3481"/>
-<text text-anchor="start" x="942.5" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00">log_template_id</text>
-<text text-anchor="start" x="1051.5" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1056.5" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="937.5,-3456 937.5,-3481 1220.5,-3481 1220.5,-3456 937.5,-3456"/>
-<text text-anchor="start" x="942.5" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00">logical_date</text>
-<text text-anchor="start" x="1024.5" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1029.5" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1125.5" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3431 937.5,-3456 1220.5,-3456 1220.5,-3431 937.5,-3431"/>
-<text text-anchor="start" x="942.5" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_at</text>
-<text text-anchor="start" x="1015.5" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1020.5" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3406 937.5,-3431 1220.5,-3431 1220.5,-3406 937.5,-3406"/>
-<text text-anchor="start" x="942.5" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
-<text text-anchor="start" x="986.5" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="991.5" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1112.5" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3381 937.5,-3406 1220.5,-3406 1220.5,-3381 937.5,-3381"/>
-<text text-anchor="start" x="942.5" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_type</text>
-<text text-anchor="start" x="1004.5" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1009.5" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
-<text text-anchor="start" x="1121.5" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="937.5,-3356 937.5,-3381 1220.5,-3381 1220.5,-3356 937.5,-3356"/>
-<text text-anchor="start" x="942.5" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
-<text text-anchor="start" x="1012.5" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1017.5" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<polygon fill="none" stroke="black" points="937.5,-3331 937.5,-3356 1220.5,-3356 1220.5,-3331 937.5,-3331"/>
-<text text-anchor="start" x="942.5" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
-<text text-anchor="start" x="977.5" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="982.5" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
-<polygon fill="none" stroke="black" points="937.5,-3306 937.5,-3331 1220.5,-3331 1220.5,-3306 937.5,-3306"/>
-<text text-anchor="start" x="942.5" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00">triggered_by</text>
-<text text-anchor="start" x="1030.5" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1035.5" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
-<polygon fill="none" stroke="black" points="937.5,-3281 937.5,-3306 1220.5,-3306 1220.5,-3281 937.5,-3281"/>
-<text text-anchor="start" x="942.5" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1021.5" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1026.5" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<title>dag_code</title>
+<polygon fill="none" stroke="black" points="937,-2056 937,-2084 1267,-2084 1267,-2056 937,-2056"/>
+<text text-anchor="start" x="1059.5" y="-2067.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_code</text>
+<polygon fill="none" stroke="black" points="937,-2031 937,-2056 1267,-2056 1267,-2031 937,-2031"/>
+<text text-anchor="start" x="942" y="-2040.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="955" y="-2040.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="960" y="-2040.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<text text-anchor="start" x="1012" y="-2040.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-2006 937,-2031 1267,-2031 1267,-2006 937,-2006"/>
+<text text-anchor="start" x="942" y="-2015.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="988" y="-2015.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="993" y="-2015.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1114" y="-2015.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-1981 937,-2006 1267,-2006 1267,-1981 937,-1981"/>
+<text text-anchor="start" x="942" y="-1990.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
+<text text-anchor="start" x="1046" y="-1990.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1051" y="-1990.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<text text-anchor="start" x="1103" y="-1990.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-1956 937,-1981 1267,-1981 1267,-1956 937,-1956"/>
+<text text-anchor="start" x="942" y="-1965.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
+<text text-anchor="start" x="983" y="-1965.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="988" y="-1965.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<text text-anchor="start" x="1118" y="-1965.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-1931 937,-1956 1267,-1956 1267,-1931 937,-1931"/>
+<text text-anchor="start" x="942" y="-1940.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_updated</text>
+<text text-anchor="start" x="1032" y="-1940.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1037" y="-1940.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1133" y="-1940.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-1906 937,-1931 1267,-1931 1267,-1906 937,-1906"/>
+<text text-anchor="start" x="942" y="-1915.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_code</text>
+<text text-anchor="start" x="1028" y="-1915.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1033" y="-1915.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
+<text text-anchor="start" x="1083" y="-1915.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="937,-1881 937,-1906 1267,-1906 1267,-1881 937,-1881"/>
+<text text-anchor="start" x="942" y="-1890.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_code_hash</text>
+<text text-anchor="start" x="1069" y="-1890.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1074" y="-1890.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<text text-anchor="start" x="1186" y="-1890.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
-<!-- dag_version--dag_run -->
+<!-- dag_version--dag_code -->
<g id="edge23" class="edge">
-<title>dag_version--dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.28,-1907.13C835.9,-1915.94 847.19,-1926.45 856,-1939 896.67,-1996.93 883.42,-2504.74 892,-2575 921.15,-2813.65 973.02,-3081.66 1014.51,-3277.47"/>
-<text text-anchor="start" x="983.51" y="-3266.27" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="823.28" y="-1895.93" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<title>dag_version--dag_code</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.13,-1903.98C857.21,-1913.67 893.76,-1924.07 928.79,-1934.03"/>
+<text text-anchor="start" x="897.79" y="-1922.83" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="823.13" y="-1892.78" font-family="Times,serif" font-size="14.00">1</text>
</g>
-<!-- dag_code -->
+<!-- dag_run -->
<g id="node29" class="node">
-<title>dag_code</title>
-<polygon fill="none" stroke="black" points="947.5,-2038 947.5,-2066 1209.5,-2066 1209.5,-2038 947.5,-2038"/>
-<text text-anchor="start" x="1036" y="-2049.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_code</text>
-<polygon fill="none" stroke="black" points="947.5,-2013 947.5,-2038 1209.5,-2038 1209.5,-2013 947.5,-2013"/>
-<text text-anchor="start" x="952.5" y="-2022.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="965.5" y="-2022.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="970.5" y="-2022.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<text text-anchor="start" x="1022.5" y="-2022.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="947.5,-1988 947.5,-2013 1209.5,-2013 1209.5,-1988 947.5,-1988"/>
-<text text-anchor="start" x="952.5" y="-1997.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="1025.5" y="-1997.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1030.5" y="-1997.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1126.5" y="-1997.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="947.5,-1963 947.5,-1988 1209.5,-1988 1209.5,-1963 947.5,-1963"/>
-<text text-anchor="start" x="952.5" y="-1972.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
-<text text-anchor="start" x="1056.5" y="-1972.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1061.5" y="-1972.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<text text-anchor="start" x="1113.5" y="-1972.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="947.5,-1938 947.5,-1963 1209.5,-1963 1209.5,-1938 947.5,-1938"/>
-<text text-anchor="start" x="952.5" y="-1947.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc</text>
-<text text-anchor="start" x="993.5" y="-1947.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="998.5" y="-1947.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
-<text text-anchor="start" x="1128.5" y="-1947.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="947.5,-1913 947.5,-1938 1209.5,-1938 1209.5,-1913 947.5,-1913"/>
-<text text-anchor="start" x="952.5" y="-1922.8" font-family="Helvetica,sans-Serif" font-size="14.00">fileloc_hash</text>
-<text text-anchor="start" x="1034.5" y="-1922.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1039.5" y="-1922.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BIGINT]</text>
-<text text-anchor="start" x="1103.5" y="-1922.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="947.5,-1888 947.5,-1913 1209.5,-1913 1209.5,-1888 947.5,-1888"/>
-<text text-anchor="start" x="952.5" y="-1897.8" font-family="Helvetica,sans-Serif" font-size="14.00">source_code</text>
-<text text-anchor="start" x="1038.5" y="-1897.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1043.5" y="-1897.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TEXT]</text>
-<text text-anchor="start" x="1093.5" y="-1897.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<title>dag_run</title>
+<polygon fill="none" stroke="black" points="961,-3806 961,-3834 1244,-3834 1244,-3806 961,-3806"/>
+<text text-anchor="start" x="1066" y="-3817.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run</text>
+<polygon fill="none" stroke="black" points="961,-3781 961,-3806 1244,-3806 1244,-3781 961,-3781"/>
+<text text-anchor="start" x="966" y="-3790.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="979" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="984" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1061" y="-3790.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3756 961,-3781 1244,-3781 1244,-3756 961,-3756"/>
+<text text-anchor="start" x="966" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00">backfill_id</text>
+<text text-anchor="start" x="1036" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1041" y="-3765.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="961,-3731 961,-3756 1244,-3756 1244,-3731 961,-3731"/>
+<text text-anchor="start" x="966" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00">clear_number</text>
+<text text-anchor="start" x="1062" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1067" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1144" y="-3740.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3706 961,-3731 1244,-3731 1244,-3706 961,-3706"/>
+<text text-anchor="start" x="966" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00">conf</text>
+<text text-anchor="start" x="997" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1002" y="-3715.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="961,-3681 961,-3706 1244,-3706 1244,-3681 961,-3681"/>
+<text text-anchor="start" x="966" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00">creating_job_id</text>
+<text text-anchor="start" x="1070" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1075" y="-3690.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="961,-3656 961,-3681 1244,-3681 1244,-3656 961,-3656"/>
+<text text-anchor="start" x="966" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1012" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1017" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1138" y="-3665.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3631 961,-3656 1244,-3656 1244,-3631 961,-3631"/>
+<text text-anchor="start" x="966" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
+<text text-anchor="start" x="1070" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1075" y="-3640.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<polygon fill="none" stroke="black" points="961,-3606 961,-3631 1244,-3631 1244,-3606 961,-3606"/>
+<text text-anchor="start" x="966" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_end</text>
+<text text-anchor="start" x="1090" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1095" y="-3615.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3581 961,-3606 1244,-3606 1244,-3581 961,-3581"/>
+<text text-anchor="start" x="966" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_interval_start</text>
+<text text-anchor="start" x="1096" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1101" y="-3590.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3556 961,-3581 1244,-3581 1244,-3556 961,-3556"/>
+<text text-anchor="start" x="966" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00">end_date</text>
+<text text-anchor="start" x="1030" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1035" y="-3565.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3531 961,-3556 1244,-3556 1244,-3531 961,-3531"/>
+<text text-anchor="start" x="966" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00">external_trigger</text>
+<text text-anchor="start" x="1077" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1082" y="-3540.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BOOLEAN]</text>
+<polygon fill="none" stroke="black" points="961,-3506 961,-3531 1244,-3531 1244,-3506 961,-3506"/>
+<text text-anchor="start" x="966" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00">last_scheduling_decision</text>
+<text text-anchor="start" x="1138" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1143" y="-3515.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3481 961,-3506 1244,-3506 1244,-3481 961,-3481"/>
+<text text-anchor="start" x="966" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00">log_template_id</text>
+<text text-anchor="start" x="1075" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1080" y="-3490.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="961,-3456 961,-3481 1244,-3481 1244,-3456 961,-3456"/>
+<text text-anchor="start" x="966" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00">logical_date</text>
+<text text-anchor="start" x="1048" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1053" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1149" y="-3465.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3431 961,-3456 1244,-3456 1244,-3431 961,-3431"/>
+<text text-anchor="start" x="966" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00">queued_at</text>
+<text text-anchor="start" x="1039" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1044" y="-3440.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3406 961,-3431 1244,-3431 1244,-3406 961,-3406"/>
+<text text-anchor="start" x="966" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_id</text>
+<text text-anchor="start" x="1010" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1015" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1136" y="-3415.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3381 961,-3406 1244,-3406 1244,-3381 961,-3381"/>
+<text text-anchor="start" x="966" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00">run_type</text>
+<text text-anchor="start" x="1028" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1033" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<text text-anchor="start" x="1145" y="-3390.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="961,-3356 961,-3381 1244,-3381 1244,-3356 961,-3356"/>
+<text text-anchor="start" x="966" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00">start_date</text>
+<text text-anchor="start" x="1036" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1041" y="-3365.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<polygon fill="none" stroke="black" points="961,-3331 961,-3356 1244,-3356 1244,-3331 961,-3331"/>
+<text text-anchor="start" x="966" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00">state</text>
+<text text-anchor="start" x="1001" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1006" y="-3340.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<polygon fill="none" stroke="black" points="961,-3306 961,-3331 1244,-3331 1244,-3306 961,-3306"/>
+<text text-anchor="start" x="966" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00">triggered_by</text>
+<text text-anchor="start" x="1054" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1059" y="-3315.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(50)]</text>
+<polygon fill="none" stroke="black" points="961,-3281 961,-3306 1244,-3306 1244,-3281 961,-3281"/>
+<text text-anchor="start" x="966" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1045" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1050" y="-3290.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
</g>
-<!-- dag_version--dag_code -->
+<!-- dag_version--dag_run -->
<g id="edge24" class="edge">
-<title>dag_version--dag_code</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.19,-1904.25C861.16,-1915.11 901.86,-1926.75 939.32,-1937.47"/>
-<text text-anchor="start" x="908.32" y="-1926.27" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="823.19" y="-1908.05" font-family="Times,serif" font-size="14.00">1</text>
+<title>dag_version--dag_run</title>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.29,-1907.12C835.91,-1915.93 847.2,-1926.45 856,-1939 897.46,-1998.13 882.36,-2516.42 892,-2588 923.57,-2822.54 981.45,-3084.68 1028.3,-3277.27"/>
+<text text-anchor="start" x="997.3" y="-3266.07" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="823.29" y="-1899.67" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- serialized_dag -->
<g id="node30" class="node">
<title>serialized_dag</title>
-<polygon fill="none" stroke="black" points="943.5,-1834 943.5,-1862 1213.5,-1862 1213.5,-1834 943.5,-1834"/>
-<text text-anchor="start" x="1015" y="-1845.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
-<polygon fill="none" stroke="black" points="943.5,-1809 943.5,-1834 1213.5,-1834 1213.5,-1809 943.5,-1809"/>
-<text text-anchor="start" x="948.5" y="-1818.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="961.5" y="-1818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="966.5" y="-1818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<text text-anchor="start" x="1018.5" y="-1818.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="943.5,-1784 943.5,-1809 1213.5,-1809 1213.5,-1784 943.5,-1784"/>
-<text text-anchor="start" x="948.5" y="-1793.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="1021.5" y="-1793.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1026.5" y="-1793.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1122.5" y="-1793.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="943.5,-1759 943.5,-1784 1213.5,-1784 1213.5,-1759 943.5,-1759"/>
-<text text-anchor="start" x="948.5" y="-1768.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
-<text text-anchor="start" x="1015.5" y="-1768.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1020.5" y="-1768.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
-<text text-anchor="start" x="1132.5" y="-1768.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="943.5,-1734 943.5,-1759 1213.5,-1759 1213.5,-1734 943.5,-1734"/>
-<text text-anchor="start" x="948.5" y="-1743.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
-<text text-anchor="start" x="994.5" y="-1743.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="999.5" y="-1743.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<text text-anchor="start" x="1120.5" y="-1743.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="943.5,-1709 943.5,-1734 1213.5,-1734 1213.5,-1709 943.5,-1709"/>
-<text text-anchor="start" x="948.5" y="-1718.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
-<text text-anchor="start" x="1052.5" y="-1718.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1057.5" y="-1718.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
-<text text-anchor="start" x="1109.5" y="-1718.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="943.5,-1684 943.5,-1709 1213.5,-1709 1213.5,-1684 943.5,-1684"/>
-<text text-anchor="start" x="948.5" y="-1693.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
-<text text-anchor="start" x="979.5" y="-1693.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="984.5" y="-1693.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
-<polygon fill="none" stroke="black" points="943.5,-1659 943.5,-1684 1213.5,-1684 1213.5,-1659 943.5,-1659"/>
-<text text-anchor="start" x="948.5" y="-1668.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
-<text text-anchor="start" x="1070.5" y="-1668.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1075.5" y="-1668.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
-<polygon fill="none" stroke="black" points="943.5,-1634 943.5,-1659 1213.5,-1659 1213.5,-1634 943.5,-1634"/>
-<text text-anchor="start" x="948.5" y="-1643.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
-<text text-anchor="start" x="1067.5" y="-1643.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1072.5" y="-1643.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
+<polygon fill="none" stroke="black" points="967,-1827 967,-1855 1237,-1855 1237,-1827 967,-1827"/>
+<text text-anchor="start" x="1038.5" y="-1838.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">serialized_dag</text>
+<polygon fill="none" stroke="black" points="967,-1802 967,-1827 1237,-1827 1237,-1802 967,-1802"/>
+<text text-anchor="start" x="972" y="-1811.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="985" y="-1811.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="990" y="-1811.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<text text-anchor="start" x="1042" y="-1811.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="967,-1777 967,-1802 1237,-1802 1237,-1777 967,-1777"/>
+<text text-anchor="start" x="972" y="-1786.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="1045" y="-1786.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1050" y="-1786.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1146" y="-1786.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="967,-1752 967,-1777 1237,-1777 1237,-1752 967,-1752"/>
+<text text-anchor="start" x="972" y="-1761.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_hash</text>
+<text text-anchor="start" x="1039" y="-1761.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1044" y="-1761.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(32)]</text>
+<text text-anchor="start" x="1156" y="-1761.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="967,-1727 967,-1752 1237,-1752 1237,-1727 967,-1727"/>
+<text text-anchor="start" x="972" y="-1736.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_id</text>
+<text text-anchor="start" x="1018" y="-1736.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1023" y="-1736.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<text text-anchor="start" x="1144" y="-1736.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="967,-1702 967,-1727 1237,-1727 1237,-1702 967,-1702"/>
+<text text-anchor="start" x="972" y="-1711.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_version_id</text>
+<text text-anchor="start" x="1076" y="-1711.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1081" y="-1711.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [UUID]</text>
+<text text-anchor="start" x="1133" y="-1711.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="967,-1677 967,-1702 1237,-1702 1237,-1677 967,-1677"/>
+<text text-anchor="start" x="972" y="-1686.8" font-family="Helvetica,sans-Serif" font-size="14.00">data</text>
+<text text-anchor="start" x="1003" y="-1686.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1008" y="-1686.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [JSON]</text>
+<polygon fill="none" stroke="black" points="967,-1652 967,-1677 1237,-1677 1237,-1652 967,-1652"/>
+<text text-anchor="start" x="972" y="-1661.8" font-family="Helvetica,sans-Serif" font-size="14.00">data_compressed</text>
+<text text-anchor="start" x="1094" y="-1661.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1099" y="-1661.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [BYTEA]</text>
+<polygon fill="none" stroke="black" points="967,-1627 967,-1652 1237,-1652 1237,-1627 967,-1627"/>
+<text text-anchor="start" x="972" y="-1636.8" font-family="Helvetica,sans-Serif" font-size="14.00">processor_subdir</text>
+<text text-anchor="start" x="1091" y="-1636.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1096" y="-1636.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(2000)]</text>
</g>
<!-- dag_version--serialized_dag -->
<g id="edge25" class="edge">
<title>dag_version--serialized_dag</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.19,-1820.12C859.81,-1809.73 898.98,-1798.63 935.33,-1788.32"/>
-<text text-anchor="start" x="904.33" y="-1777.12" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="823.19" y="-1808.92" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M823.13,-1820.02C867.05,-1807.53 915.07,-1793.87 958.66,-1781.48"/>
+<text text-anchor="start" x="927.66" y="-1770.28" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="823.13" y="-1808.82" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--dagrun_asset_event -->
<g id="edge28" class="edge">
<title>dag_run--dagrun_asset_event</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.17,-3796.07C1250.42,-3820.91 1274.78,-3843.98 1301,-3863 1310.63,-3869.98 1321.24,-3876.06 1332.28,-3881.34"/>
-<text text-anchor="start" x="1301.28" y="-3870.14" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.17" y="-3784.87" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.75,-3776.45C1280.81,-3808.66 1313.18,-3839.01 1348,-3863 1357.68,-3869.67 1368.26,-3875.52 1379.23,-3880.65"/>
+<text text-anchor="start" x="1348.23" y="-3869.45" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.75" y="-3765.25" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_instance -->
<g id="edge29" class="edge">
<title>dag_run--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.01,-3313.81C1240.58,-3293.59 1253.04,-3273.46 1265,-3254 1276.74,-3234.9 1288.81,-3215.14 1300.91,-3195.23"/>
-<text text-anchor="start" x="1269.91" y="-3184.03" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.01" y="-3302.61" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.73,-3343.34C1272.34,-3313.55 1292.95,-3283.16 1312,-3254 1323.9,-3235.79 1335.97,-3216.87 1347.99,-3197.73"/>
+<text text-anchor="start" x="1316.99" y="-3186.53" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.73" y="-3332.14" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_instance -->
<g id="edge30" class="edge">
<title>dag_run--task_instance</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.01,-3331.75C1240.58,-3311.59 1253.04,-3291.46 1265,-3272 1276.74,-3252.9 1288.81,-3233.14 1300.91,-3213.19"/>
-<text text-anchor="start" x="1269.91" y="-3201.99" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.01" y="-3320.55" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.73,-3361.16C1272.34,-3331.55 1292.95,-3301.16 1312,-3272 1323.9,-3253.79 1335.97,-3234.87 1347.99,-3215.7"/>
+<text text-anchor="start" x="1316.99" y="-3204.5" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.73" y="-3349.96" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- backfill_dag_run -->
<g id="node32" class="node">
<title>backfill_dag_run</title>
-<polygon fill="none" stroke="black" points="1329,-3822 1329,-3850 1598,-3850 1598,-3822 1329,-3822"/>
-<text text-anchor="start" x="1391" y="-3833.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">backfill_dag_run</text>
-<polygon fill="none" stroke="black" points="1329,-3797 1329,-3822 1598,-3822 1598,-3797 1329,-3797"/>
-<text text-anchor="start" x="1334" y="-3806.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1347" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1352" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1429" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1329,-3772 1329,-3797 1598,-3797 1598,-3772 1329,-3772"/>
-<text text-anchor="start" x="1334" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00">backfill_id</text>
-<text text-anchor="start" x="1404" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1409" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1486" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1329,-3747 1329,-3772 1598,-3772 1598,-3747 1329,-3747"/>
-<text text-anchor="start" x="1334" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="1411" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1416" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="1329,-3722 1329,-3747 1598,-3747 1598,-3722 1329,-3722"/>
-<text text-anchor="start" x="1334" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00">exception_reason</text>
-<text text-anchor="start" x="1455" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1460" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
-<polygon fill="none" stroke="black" points="1329,-3697 1329,-3722 1598,-3722 1598,-3697 1329,-3697"/>
-<text text-anchor="start" x="1334" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00">logical_date</text>
-<text text-anchor="start" x="1416" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1421" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1517" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1329,-3672 1329,-3697 1598,-3697 1598,-3672 1329,-3672"/>
-<text text-anchor="start" x="1334" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00">sort_ordinal</text>
-<text text-anchor="start" x="1416" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1421" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1498" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1376,-3822 1376,-3850 1645,-3850 1645,-3822 1376,-3822"/>
+<text text-anchor="start" x="1438" y="-3833.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">backfill_dag_run</text>
+<polygon fill="none" stroke="black" points="1376,-3797 1376,-3822 1645,-3822 1645,-3797 1376,-3797"/>
+<text text-anchor="start" x="1381" y="-3806.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1394" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1399" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1476" y="-3806.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1376,-3772 1376,-3797 1645,-3797 1645,-3772 1376,-3772"/>
+<text text-anchor="start" x="1381" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00">backfill_id</text>
+<text text-anchor="start" x="1451" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1456" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1533" y="-3781.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1376,-3747 1376,-3772 1645,-3772 1645,-3747 1376,-3747"/>
+<text text-anchor="start" x="1381" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="1458" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1463" y="-3756.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1376,-3722 1376,-3747 1645,-3747 1645,-3722 1376,-3722"/>
+<text text-anchor="start" x="1381" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00">exception_reason</text>
+<text text-anchor="start" x="1502" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1507" y="-3731.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(250)]</text>
+<polygon fill="none" stroke="black" points="1376,-3697 1376,-3722 1645,-3722 1645,-3697 1376,-3697"/>
+<text text-anchor="start" x="1381" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00">logical_date</text>
+<text text-anchor="start" x="1463" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1468" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1564" y="-3706.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1376,-3672 1376,-3697 1645,-3697 1645,-3672 1376,-3672"/>
+<text text-anchor="start" x="1381" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00">sort_ordinal</text>
+<text text-anchor="start" x="1463" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1468" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1545" y="-3681.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
</g>
<!-- dag_run--backfill_dag_run -->
<g id="edge31" class="edge">
<title>dag_run--backfill_dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.21,-3636.92C1258.53,-3653.02 1290.36,-3669.91 1320.44,-3685.87"/>
-<text text-anchor="start" x="1289.44" y="-3674.67" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.21" y="-3625.72" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.59,-3632.29C1289.4,-3651.2 1329.93,-3671.46 1367.38,-3690.19"/>
+<text text-anchor="start" x="1336.38" y="-3678.99" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.59" y="-3621.09" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- dag_run_note -->
<g id="node33" class="node">
<title>dag_run_note</title>
-<polygon fill="none" stroke="black" points="1330,-3561 1330,-3589 1596,-3589 1596,-3561 1330,-3561"/>
-<text text-anchor="start" x="1402.5" y="-3572.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run_note</text>
-<polygon fill="none" stroke="black" points="1330,-3536 1330,-3561 1596,-3561 1596,-3536 1330,-3536"/>
-<text text-anchor="start" x="1335" y="-3545.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
-<text text-anchor="start" x="1412" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1417" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1494" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1330,-3511 1330,-3536 1596,-3536 1596,-3511 1330,-3511"/>
-<text text-anchor="start" x="1335" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
-<text text-anchor="start" x="1388" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1393" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
-<polygon fill="none" stroke="black" points="1330,-3486 1330,-3511 1596,-3511 1596,-3486 1330,-3486"/>
-<text text-anchor="start" x="1335" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
-<text text-anchor="start" x="1408" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1413" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1509" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1330,-3461 1330,-3486 1596,-3486 1596,-3461 1330,-3461"/>
-<text text-anchor="start" x="1335" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
-<text text-anchor="start" x="1414" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1419" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
-<text text-anchor="start" x="1515" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="1330,-3436 1330,-3461 1596,-3461 1596,-3436 1330,-3436"/>
-<text text-anchor="start" x="1335" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="1386" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1391" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(128)]</text>
+<polygon fill="none" stroke="black" points="1377,-3561 1377,-3589 1643,-3589 1643,-3561 1377,-3561"/>
+<text text-anchor="start" x="1449.5" y="-3572.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">dag_run_note</text>
+<polygon fill="none" stroke="black" points="1377,-3536 1377,-3561 1643,-3561 1643,-3536 1377,-3536"/>
+<text text-anchor="start" x="1382" y="-3545.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">dag_run_id</text>
+<text text-anchor="start" x="1459" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1464" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1541" y="-3545.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1377,-3511 1377,-3536 1643,-3536 1643,-3511 1377,-3511"/>
+<text text-anchor="start" x="1382" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00">content</text>
+<text text-anchor="start" x="1435" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1440" y="-3520.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(1000)]</text>
+<polygon fill="none" stroke="black" points="1377,-3486 1377,-3511 1643,-3511 1643,-3486 1377,-3486"/>
+<text text-anchor="start" x="1382" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00">created_at</text>
+<text text-anchor="start" x="1455" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1460" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1556" y="-3495.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1377,-3461 1377,-3486 1643,-3486 1643,-3461 1377,-3461"/>
+<text text-anchor="start" x="1382" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00">updated_at</text>
+<text text-anchor="start" x="1461" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1466" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [TIMESTAMP]</text>
+<text text-anchor="start" x="1562" y="-3470.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1377,-3436 1377,-3461 1643,-3461 1643,-3436 1377,-3436"/>
+<text text-anchor="start" x="1382" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="1433" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1438" y="-3445.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [VARCHAR(128)]</text>
</g>
<!-- dag_run--dag_run_note -->
<g id="edge32" class="edge">
<title>dag_run--dag_run_note</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.21,-3540.51C1259.06,-3536.88 1291.47,-3533.06 1321.99,-3529.47"/>
-<text text-anchor="start" x="1311.99" y="-3518.27" font-family="Times,serif" font-size="14.00">1</text>
-<text text-anchor="start" x="1228.21" y="-3529.31" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.59,-3541.53C1289.85,-3537.29 1330.9,-3532.74 1368.73,-3528.55"/>
+<text text-anchor="start" x="1358.73" y="-3517.35" font-family="Times,serif" font-size="14.00">1</text>
+<text text-anchor="start" x="1251.59" y="-3530.33" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_reschedule -->
<g id="edge33" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.05,-3579.1C1252.41,-3583.76 1277.4,-3588.58 1301,-3593 1444.71,-3619.91 1486.55,-3602.99 1625,-3650 1650.38,-3658.62 1676.38,-3669.67 1701.39,-3681.7"/>
-<text text-anchor="start" x="1670.39" y="-3685.5" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.05" y="-3567.9" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.65,-3576C1283.44,-3581.49 1316.83,-3587.46 1348,-3593 1491.95,-3618.59 1533.55,-3602.99 1672,-3650 1697.38,-3658.62 1723.38,-3669.67 1748.39,-3681.7"/>
+<text text-anchor="start" x="1717.39" y="-3685.5" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.65" y="-3564.8" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- dag_run--task_reschedule -->
<g id="edge34" class="edge">
<title>dag_run--task_reschedule</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1228.05,-3596.85C1252.41,-3601.76 1277.4,-3606.58 1301,-3611 1444.71,-3637.91 1486.55,-3620.99 1625,-3668 1650.38,-3676.62 1676.38,-3687.67 1701.39,-3699.48"/>
-<text text-anchor="start" x="1670.39" y="-3703.28" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="1228.05" y="-3585.65" font-family="Times,serif" font-size="14.00">1</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M1251.65,-3593.57C1283.44,-3599.49 1316.83,-3605.46 1348,-3611 1491.95,-3636.59 1533.55,-3620.99 1672,-3668 1697.38,-3676.62 1723.38,-3687.67 1748.39,-3699.48"/>
+<text text-anchor="start" x="1717.39" y="-3703.28" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="1251.65" y="-3582.37" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- log_template -->
<g id="node31" class="node">
@@ -1986,9 +1991,9 @@
<!-- log_template--dag_run -->
<g id="edge27" class="edge">
<title>log_template--dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M812.72,-3512.55C850.14,-3518.98 890.84,-3525.96 928.86,-3532.49"/>
-<text text-anchor="start" x="897.86" y="-3521.29" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="812.72" y="-3501.35" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M812.77,-3511.26C857.33,-3518.49 906.98,-3526.54 952.34,-3533.89"/>
+<text text-anchor="start" x="921.34" y="-3522.69" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="812.77" y="-3500.06" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- backfill -->
<g id="node35" class="node">
@@ -2052,15 +2057,15 @@
<!-- backfill--dag_run -->
<g id="edge35" class="edge">
<title>backfill--dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M856.21,-3653.23C880.51,-3642.77 905.21,-3632.14 928.87,-3621.96"/>
-<text text-anchor="start" x="897.87" y="-3610.76" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="856.21" y="-3642.03" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M856.26,-3657.51C888.29,-3644.48 921.31,-3631.06 952.32,-3618.45"/>
+<text text-anchor="start" x="921.32" y="-3607.25" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="856.26" y="-3646.31" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- backfill--backfill_dag_run -->
<g id="edge36" class="edge">
<title>backfill--backfill_dag_run</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M856.08,-3824.78C880.07,-3833.9 904.76,-3841.72 929,-3847 1058.84,-3875.3 1097.17,-3870.28 1228,-3847 1258.57,-3841.56 1290.39,-3832.41 1320.35,-3822.07"/>
-<text text-anchor="start" x="1289.35" y="-3810.87" font-family="Times,serif" font-size="14.00">0..N</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M856.08,-3824.78C880.07,-3833.9 904.76,-3841.72 929,-3847 1079.25,-3879.74 1123.6,-3873.94 1275,-3847 1305.57,-3841.56 1337.39,-3832.41 1367.35,-3822.07"/>
+<text text-anchor="start" x="1336.35" y="-3810.87" font-family="Times,serif" font-size="14.00">0..N</text>
<text text-anchor="start" x="856.08" y="-3813.58" font-family="Times,serif" font-size="14.00">1</text>
</g>
<!-- alembic_version -->
@@ -2181,28 +2186,28 @@
<!-- ab_user_role -->
<g id="node44" class="node">
<title>ab_user_role</title>
-<polygon fill="none" stroke="black" points="988.5,-4386 988.5,-4414 1169.5,-4414 1169.5,-4386 988.5,-4386"/>
-<text text-anchor="start" x="1022" y="-4397.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_user_role</text>
-<polygon fill="none" stroke="black" points="988.5,-4361 988.5,-4386 1169.5,-4386 1169.5,-4361 988.5,-4361"/>
-<text text-anchor="start" x="993.5" y="-4370.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="1006.5" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1011.5" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1088.5" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="988.5,-4336 988.5,-4361 1169.5,-4361 1169.5,-4336 988.5,-4336"/>
-<text text-anchor="start" x="993.5" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
-<text text-anchor="start" x="1039.5" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1044.5" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="988.5,-4311 988.5,-4336 1169.5,-4336 1169.5,-4311 988.5,-4311"/>
-<text text-anchor="start" x="993.5" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
-<text text-anchor="start" x="1044.5" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1049.5" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1012,-4386 1012,-4414 1193,-4414 1193,-4386 1012,-4386"/>
+<text text-anchor="start" x="1045.5" y="-4397.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_user_role</text>
+<polygon fill="none" stroke="black" points="1012,-4361 1012,-4386 1193,-4386 1193,-4361 1012,-4361"/>
+<text text-anchor="start" x="1017" y="-4370.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1030" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1035" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1112" y="-4370.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="1012,-4336 1012,-4361 1193,-4361 1193,-4336 1012,-4336"/>
+<text text-anchor="start" x="1017" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
+<text text-anchor="start" x="1063" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1068" y="-4345.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="1012,-4311 1012,-4336 1193,-4336 1193,-4311 1012,-4311"/>
+<text text-anchor="start" x="1017" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00">user_id</text>
+<text text-anchor="start" x="1068" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1073" y="-4320.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_user--ab_user_role -->
<g id="edge63" class="edge">
<title>ab_user--ab_user_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M825.76,-4476.34C877.28,-4453.15 933.55,-4427.81 979.8,-4406.99"/>
-<text text-anchor="start" x="948.8" y="-4395.79" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="825.76" y="-4465.14" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M825.52,-4480.19C884.61,-4455.05 950.81,-4426.89 1003.49,-4404.48"/>
+<text text-anchor="start" x="972.49" y="-4393.28" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="825.52" y="-4468.99" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- ab_register_user -->
<g id="node45" class="node">
@@ -2292,28 +2297,28 @@
<!-- ab_permission_view_role -->
<g id="node48" class="node">
<title>ab_permission_view_role</title>
-<polygon fill="none" stroke="black" points="962.5,-4236 962.5,-4264 1195.5,-4264 1195.5,-4236 962.5,-4236"/>
-<text text-anchor="start" x="967.5" y="-4247.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission_view_role</text>
-<polygon fill="none" stroke="black" points="962.5,-4211 962.5,-4236 1195.5,-4236 1195.5,-4211 962.5,-4211"/>
-<text text-anchor="start" x="967.5" y="-4220.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
-<text text-anchor="start" x="980.5" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="985.5" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<text text-anchor="start" x="1062.5" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
-<polygon fill="none" stroke="black" points="962.5,-4186 962.5,-4211 1195.5,-4211 1195.5,-4186 962.5,-4186"/>
-<text text-anchor="start" x="967.5" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00">permission_view_id</text>
-<text text-anchor="start" x="1101.5" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1106.5" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
-<polygon fill="none" stroke="black" points="962.5,-4161 962.5,-4186 1195.5,-4186 1195.5,-4161 962.5,-4161"/>
-<text text-anchor="start" x="967.5" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
-<text text-anchor="start" x="1013.5" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
-<text text-anchor="start" x="1018.5" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="986,-4236 986,-4264 1219,-4264 1219,-4236 986,-4236"/>
+<text text-anchor="start" x="991" y="-4247.2" font-family="Helvetica,sans-Serif" font-weight="bold" font-size="16.00">ab_permission_view_role</text>
+<polygon fill="none" stroke="black" points="986,-4211 986,-4236 1219,-4236 1219,-4211 986,-4211"/>
+<text text-anchor="start" x="991" y="-4220.8" font-family="Helvetica,sans-Serif" text-decoration="underline" font-size="14.00">id</text>
+<text text-anchor="start" x="1004" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1009" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<text text-anchor="start" x="1086" y="-4220.8" font-family="Helvetica,sans-Serif" font-size="14.00"> NOT NULL</text>
+<polygon fill="none" stroke="black" points="986,-4186 986,-4211 1219,-4211 1219,-4186 986,-4186"/>
+<text text-anchor="start" x="991" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00">permission_view_id</text>
+<text text-anchor="start" x="1125" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1130" y="-4195.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
+<polygon fill="none" stroke="black" points="986,-4161 986,-4186 1219,-4186 1219,-4161 986,-4161"/>
+<text text-anchor="start" x="991" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00">role_id</text>
+<text text-anchor="start" x="1037" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> </text>
+<text text-anchor="start" x="1042" y="-4170.8" font-family="Helvetica,sans-Serif" font-size="14.00"> [INTEGER]</text>
</g>
<!-- ab_permission_view--ab_permission_view_role -->
<g id="edge65" class="edge">
<title>ab_permission_view--ab_permission_view_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M777.72,-4183.17C831.34,-4188.51 897.44,-4195.08 953.91,-4200.7"/>
-<text text-anchor="start" x="922.91" y="-4189.5" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="777.72" y="-4171.97" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M777.69,-4182.61C837.68,-4188.25 913.92,-4195.41 977.3,-4201.37"/>
+<text text-anchor="start" x="946.3" y="-4190.17" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="777.69" y="-4171.41" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- ab_view_menu -->
<g id="node49" class="node">
@@ -2357,16 +2362,16 @@
<!-- ab_role--ab_user_role -->
<g id="edge67" class="edge">
<title>ab_role--ab_user_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M804.08,-4313.35C861.05,-4323.69 926.98,-4335.67 979.82,-4345.26"/>
-<text text-anchor="start" x="948.82" y="-4334.06" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="804.08" y="-4302.15" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M804.03,-4312.05C868.01,-4323.03 944.1,-4336.08 1003.24,-4346.23"/>
+<text text-anchor="start" x="972.24" y="-4335.03" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="804.03" y="-4300.85" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- ab_role--ab_permission_view_role -->
<g id="edge68" class="edge">
<title>ab_role--ab_permission_view_role</title>
-<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M804.08,-4265.37C851.97,-4256.2 906.2,-4245.81 953.67,-4236.72"/>
-<text text-anchor="start" x="922.67" y="-4225.52" font-family="Times,serif" font-size="14.00">0..N</text>
-<text text-anchor="start" x="804.08" y="-4254.17" font-family="Times,serif" font-size="14.00">{0,1}</text>
+<path fill="none" stroke="#7f7f7f" stroke-dasharray="5,2" d="M804.03,-4266.74C858.95,-4256.8 922.81,-4245.25 977.2,-4235.4"/>
+<text text-anchor="start" x="946.2" y="-4224.2" font-family="Times,serif" font-size="14.00">0..N</text>
+<text text-anchor="start" x="804.03" y="-4255.54" font-family="Times,serif" font-size="14.00">{0,1}</text>
</g>
<!-- alembic_version_fab -->
<g id="node51" class="node">
diff --git a/tests/dag_processing/test_job_runner.py b/tests/dag_processing/test_job_runner.py
index 2bf0bcb6dbb..5a562224735 100644
--- a/tests/dag_processing/test_job_runner.py
+++ b/tests/dag_processing/test_job_runner.py
@@ -1054,7 +1054,7 @@ class TestDagProcessorJobRunner:
# Assert dag not deleted in SDM
assert SerializedDagModel.has_dag("test_zip_dag")
# assert code not deleted
- assert DagCode.has_dag(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
# assert dag still active
assert dag.get_is_active()
@@ -1087,7 +1087,7 @@ class TestDagProcessorJobRunner:
# Deleting the python file should not delete SDM for versioning sake
assert SerializedDagModel.has_dag("test_zip_dag")
# assert code not deleted for versioning sake
- assert DagCode.has_dag(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
# assert dagversion was not deleted
assert DagVersion.get_latest_version(dag.dag_id)
# assert dag deactivated
@@ -1106,7 +1106,7 @@ class TestDagProcessorJobRunner:
assert SerializedDagModel.has_dag("miscellaneous_test_dag")
assert dag.get_is_active()
- assert DagCode.has_dag(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
manager = DagProcessorJobRunner(
job=Job(),
@@ -1125,7 +1125,7 @@ class TestDagProcessorJobRunner:
assert SerializedDagModel.has_dag("miscellaneous_test_dag")
assert dag.get_is_active()
- assert DagCode.has_dag(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
@conf_vars(
{
diff --git a/tests/models/test_dagcode.py b/tests/models/test_dagcode.py
index fc1dfa330f7..a922fff1618 100644
--- a/tests/models/test_dagcode.py
+++ b/tests/models/test_dagcode.py
@@ -20,9 +20,10 @@ from __future__ import annotations
from unittest.mock import patch
import pytest
+from sqlalchemy.exc import IntegrityError
import airflow.example_dags as example_dags_module
-from airflow.exceptions import AirflowException
+from airflow.decorators import task as task_decorator
from airflow.models import DagBag
from airflow.models.dag import DAG
from airflow.models.dag_version import DagVersion
@@ -56,14 +57,20 @@ class TestDagCode:
clear_db_dags()
clear_db_dag_code()
- def _write_two_example_dags(self):
+ def _write_two_example_dags(self, session):
example_dags = make_example_dags(example_dags_module)
bash_dag = example_dags["example_bash_operator"]
+ SDM.write_dag(bash_dag)
dag_version = DagVersion.get_latest_version("example_bash_operator")
- DagCode(dag_version, bash_dag.fileloc).sync_to_db()
+ x = DagCode(dag_version, bash_dag.fileloc)
+ session.add(x)
+ session.commit()
xcom_dag = example_dags["example_xcom"]
+ SDM.write_dag(xcom_dag)
dag_version = DagVersion.get_latest_version("example_xcom")
- DagCode(dag_version, xcom_dag.fileloc).sync_to_db()
+ x = DagCode(dag_version, xcom_dag.fileloc)
+ session.add(x)
+ session.commit()
return [bash_dag, xcom_dag]
def _write_example_dags(self):
@@ -78,24 +85,22 @@ class TestDagCode:
self._compare_example_dags(example_dags)
- @patch.object(DagCode, "dag_fileloc_hash")
- def test_detecting_duplicate_key(self, mock_hash):
+ @patch.object(DagCode, "dag_source_hash")
+ def test_detecting_duplicate_key(self, mock_hash, session):
"""Dag code detects duplicate key."""
mock_hash.return_value = 0
- with pytest.raises(AirflowException):
- self._write_two_example_dags()
+ with pytest.raises(IntegrityError):
+ self._write_two_example_dags(session)
def _compare_example_dags(self, example_dags):
with create_session() as session:
for dag in example_dags.values():
- assert DagCode.has_dag(dag.fileloc)
- dag_fileloc_hash = DagCode.dag_fileloc_hash(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
result = (
- session.query(DagCode.fileloc, DagCode.fileloc_hash, DagCode.source_code)
- .filter(DagCode.fileloc == dag.fileloc)
- .filter(DagCode.fileloc_hash == dag_fileloc_hash)
- .order_by(DagCode.created_at.desc())
+ session.query(DagCode.fileloc, DagCode.dag_id, DagCode.source_code)
+ .filter(DagCode.dag_id == dag.dag_id)
+ .order_by(DagCode.last_updated.desc())
.limit(1)
.one()
)
@@ -116,7 +121,7 @@ class TestDagCode:
# Mock that there is no access to the Dag File
with patch("airflow.models.dagcode.open_maybe_zipped") as mock_open:
mock_open.side_effect = FileNotFoundError
- dag_code = DagCode.get_code_by_fileloc(example_dag.fileloc)
+ dag_code = DagCode.code(example_dag.dag_id)
for test_string in ["example_bash_operator", "also_run_this", "run_this_last"]:
assert test_string in dag_code
@@ -129,7 +134,7 @@ class TestDagCode:
result = (
session.query(DagCode)
.filter(DagCode.fileloc == example_dag.fileloc)
- .order_by(DagCode.created_at.desc())
+ .order_by(DagCode.last_updated.desc())
.limit(1)
.one()
)
@@ -139,21 +144,21 @@ class TestDagCode:
example_dag = make_example_dags(example_dags_module).get("example_bash_operator")
SDM.write_dag(example_dag, processor_subdir="/tmp")
- with patch("airflow.models.dagcode.DagCode._get_code_from_file") as mock_code:
+ with patch("airflow.models.dagcode.DagCode.get_code_from_file") as mock_code:
mock_code.return_value = "# dummy code"
SDM.write_dag(example_dag)
new_result = (
session.query(DagCode)
.filter(DagCode.fileloc == example_dag.fileloc)
- .order_by(DagCode.created_at.desc())
+ .order_by(DagCode.last_updated.desc())
.limit(1)
.one()
)
assert new_result.fileloc == example_dag.fileloc
assert new_result.source_code != result.source_code
- assert new_result.created_at > result.created_at
+ assert new_result.last_updated > result.last_updated
def test_has_dag(self, dag_maker):
"""Test has_dag method."""
@@ -167,4 +172,26 @@ class TestDagCode:
dag2.sync_to_db()
SDM.write_dag(dag2)
- assert DagCode.has_dag(dag.fileloc)
+ assert DagCode.has_dag(dag.dag_id)
+
+ def test_update_source_code(self, dag_maker, session):
+ """Test that dag code can be updated."""
+
+ with dag_maker("dag1") as dag:
+
+ @task_decorator
+ def mytask():
+ print("task4")
+
+ mytask()
+ dag.sync_to_db()
+ SDM.write_dag(dag)
+ dag_code = DagCode.get_latest_dagcode(dag.dag_id)
+ dag_code.source_code_hash = 2
+ session.add(dag_code)
+ session.commit()
+ dagcode2 = DagCode.get_latest_dagcode(dag.dag_id)
+ assert dagcode2.source_code_hash == 2
+ DagCode.update_source_code(dag)
+ dag_code3 = DagCode.get_latest_dagcode(dag.dag_id)
+ assert dag_code3.source_code_hash != 2
diff --git a/tests/models/test_serialized_dag.py b/tests/models/test_serialized_dag.py
index 3838e3bdab9..bf59aa4afbe 100644
--- a/tests/models/test_serialized_dag.py
+++ b/tests/models/test_serialized_dag.py
@@ -30,7 +30,6 @@ from airflow.decorators import task as task_decorator
from airflow.models.dag import DAG
from airflow.models.dag_version import DagVersion
from airflow.models.dagbag import DagBag
-from airflow.models.dagcode import DagCode
from airflow.models.serialized_dag import SerializedDagModel as SDM
from airflow.operators.empty import EmptyOperator
from airflow.providers.standard.operators.bash import BashOperator
@@ -72,10 +71,6 @@ class TestSerializedDagModel:
yield
db.clear_db_serialized_dags()
- def test_dag_fileloc_hash(self):
- """Verifies the correctness of hashing file path."""
- assert DagCode.dag_fileloc_hash("/airflow/dags/test_dag.py") == 33826252060516589
-
def _write_example_dags(self):
example_dags = make_example_dags(example_dags_module)
for dag in example_dags.values():