[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1166300450 ## airflow/models/dag.py: ## @@ -2789,7 +2789,9 @@ def bulk_write_to_db( orm_dag.description = dag.description orm_dag.max_active_tasks =

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1166297704 ## airflow/jobs/scheduler_job_runner.py: ## @@ -304,26 +323,24 @@ def _executable_task_instances_to_queued(self, max_tis: int, session: Session) -

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1166296913 ## airflow/jobs/scheduler_job_runner.py: ## @@ -231,28 +255,21 @@ def is_alive(self, grace_multiplier: float | None = None) -> bool: <

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1161983489 ## airflow/jobs/scheduler_job.py: ## @@ -83,6 +84,17 @@ DM = DagModel +@dataclass +class ConcurrencyMap: +"""Dataclass to represent concurrency maps""" + +

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1149027949 ## airflow/jobs/scheduler_job.py: ## @@ -83,6 +84,17 @@ DM = DagModel +@dataclass +class ConcurrencyMap: +"""Dataclass to represent concurrency maps""" + +

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1149027949 ## airflow/jobs/scheduler_job.py: ## @@ -83,6 +84,17 @@ DM = DagModel +@dataclass +class ConcurrencyMap: +"""Dataclass to represent concurrency maps""" + +

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1149027949 ## airflow/jobs/scheduler_job.py: ## @@ -83,6 +84,17 @@ DM = DagModel +@dataclass +class ConcurrencyMap: +"""Dataclass to represent concurrency maps""" + +

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1149016329 ## airflow/jobs/scheduler_job.py: ## @@ -83,6 +84,17 @@ DM = DagModel +@dataclass +class ConcurrencyMap: +"""Dataclass to represent concurrency maps""" + +

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1149012834 ## airflow/jobs/scheduler_job.py: ## @@ -219,28 +231,27 @@ def is_alive(self, grace_multiplier: float | None = None) -> bool: and (timezone.utcnow() -

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1138123017 ## airflow/jobs/scheduler_job.py: ## @@ -221,26 +221,31 @@ def is_alive(self, grace_multiplier: float | None = None) -> bool: def __get_concurrency_maps(

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1138123017 ## airflow/jobs/scheduler_job.py: ## @@ -221,26 +221,31 @@ def is_alive(self, grace_multiplier: float | None = None) -> bool: def __get_concurrency_maps(

[GitHub] [airflow] uranusjr commented on a diff in pull request #29094: Add `max_active_tis_per_dagrun` for Dynamic Task Mapping

uranusjr commented on code in PR #29094: URL: https://github.com/apache/airflow/pull/29094#discussion_r1138121909 ## airflow/jobs/scheduler_job.py: ## @@ -221,26 +221,31 @@ def is_alive(self, grace_multiplier: float | None = None) -> bool: def __get_concurrency_maps(