Bump mypy to 1.16.1 #52997

gopidesupavan · 2025-07-07T22:11:46Z

^ Add meaningful description above
Read the Pull Request Guidelines for more information.
In case of fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
In case of a new dependency, check compliance with the ASF 3rd Party License Policy.
In case of backwards incompatible changes please leave a note in a newsfragment file, named {pr_number}.significant.rst or {issue_number}.significant.rst, in airflow-core/newsfragments.

airflow-core/src/airflow/serialization/serde.py

gopidesupavan · 2025-07-08T00:10:56Z

Will extract into multiple PR, thats will work to iterate easily, core, task-sdk, providers(may be multiple prs)

gopidesupavan · 2025-07-08T07:55:31Z

have extracted here for airflow-core #53004

gopidesupavan · 2025-07-08T21:39:25Z

extracted task-dk mypy fixes here: #53047

gopidesupavan · 2025-07-09T12:12:39Z

amazon: #53088

gopidesupavan · 2025-07-09T19:46:50Z

Provider mypy fixes required:

providers/elasticsearch/src/airflow/providers/elasticsearch/version_compat.py:48: error:
Incompatible types in assignment (expression has type
"type[list[tuple[str, str]]]", variable has type
"UnionType[list[StructuredLogMessage], str]")  [assignment]
        EsLogMsgType = list[tuple[str, str]]  # type: ignore[misc]
                       ^~~~~~~~~~~~~~~~~~~~~
providers/elasticsearch/src/airflow/providers/elasticsearch/version_compat.py:48: note: Error code "assignment" not covered by "type: ignore" comment
providers/edge3/src/airflow/providers/edge3/models/edge_worker.py:113: error:
Incompatible return value type (got "Any | None", expected "dict[Any, Any]") 
[return-value]
            return json.loads(self.sysinfo) if self.sysinfo else None
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py:105: error:
Argument 1 to "get_lb_policy" of "CassandraHook" has incompatible type
"Any | None"; expected "str"  [arg-type]
            lb_policy = self.get_lb_policy(policy_name, policy_args)
                                           ^~~~~~~~~~~
providers/keycloak/src/airflow/providers/keycloak/auth_manager/keycloak_auth_manager.py:211: error:
Redundant cast to "Literal['GET', 'POST', 'PUT', 'DELETE', 'MENU']" 
[redundant-cast]
                    (cast("ExtendedResourceMethod", "MENU"), menu_item.val...
                     ^
providers/http/src/airflow/providers/http/hooks/http.py:238: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "int")  [assignment]
            session.max_redirects = self.merged_extra.get("max_redirects",...
                                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/samba/src/airflow/providers/samba/hooks/samba.py:260: error: Missing
positional argument "path" in call to "__call__" of "_Wrapped"  [call-arg]
            with open(local_filepath, "rb") as f, self.open_file(destinati...
                                                  ^~~~~~~~~~~~~~~~~~~~~~~~...
providers/samba/src/airflow/providers/samba/hooks/samba.py:260: error: Argument
1 to "__call__" of "_Wrapped" has incompatible type "str"; expected "SambaHook" 
[arg-type]
    ... open(local_filepath, "rb") as f, self.open_file(destination_filepath,...
                                                        ^~~~~~~~~~~~~~~~~~~~
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py:111: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "dict[Any, Any]")  [assignment]
                metadata: dict = body.get("metadata", None)
                                 ^~~~~~~~~~~~~~~~~~~~~~~~~~
providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py:55: error:
Incompatible types in assignment (expression has type
"type[list[tuple[str, str]]]", variable has type
"UnionType[list[StructuredLogMessage], str]")  [assignment]
        OsLogMsgType = list[tuple[str, str]]  # type: ignore[misc]
                       ^~~~~~~~~~~~~~~~~~~~~
providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py:55: note: Error code "assignment" not covered by "type: ignore" comment
providers/google/src/airflow/providers/google/cloud/links/kubernetes_engine.py:62: error:
Item "None" of "Any | None" has no attribute "name"  [union-attr]
                cluster_name=cluster.name,
                             ^~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:265: error:
Incompatible types in assignment (expression has type "int", variable has type
"VerificationStatus")  [assignment]
                    monitoring_v3.NotificationChannel.VerificationStatus.V...
                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:277: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    channel.name = None
                                   ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:287: error:
Incompatible types in assignment (expression has type "None", variable has type
"MutationRecord")  [assignment]
                policy.creation_record = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:288: error:
Incompatible types in assignment (expression has type "None", variable has type
"MutationRecord")  [assignment]
                policy.mutation_record = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:304: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    policy.name = None
                                  ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:306: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                        condition.name = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:535: error:
Incompatible types in assignment (expression has type "int", variable has type
"VerificationStatus")  [assignment]
                    monitoring_v3.NotificationChannel.VerificationStatus.V...
                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:547: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    channel.name = None
                                   ^~~~
providers/samba/src/airflow/providers/samba/transfers/gcs_to_samba.py:200: error:
Missing positional argument "path" in call to "__call__" of "_Wrapped" 
[call-arg]
            samba_hook.makedirs(dir_path, exist_ok=True)
            ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/samba/src/airflow/providers/samba/transfers/gcs_to_samba.py:200: error:
Argument 1 to "__call__" of "_Wrapped" has incompatible type "str"; expected
"SambaHook"  [arg-type]
            samba_hook.makedirs(dir_path, exist_ok=True)
                                ^~~~~~~~
providers/google/src/airflow/providers/google/cloud/sensors/datafusion.py:135: error:
Unsupported operand types for in ("Any | None" and "Iterable[str]")  [operator]
            return pipeline_status in self.expected_statuses
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:108: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance], Any]") 
[misc]
            def on_task_instance_running(
            ^
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:260: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance | TaskInstance], None]")
 [misc]
            def on_task_instance_success(
            ^
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:389: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, str | BaseException | None, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance | TaskInstance, str | BaseException | None], None]")
 [misc]
            def on_task_instance_failed(
            ^
providers/google/src/airflow/providers/google/cloud/sensors/dataflow.py:363: error:
Incompatible return value type (got "list[dict[Any, Any]] | Any", expected
"bool")  [return-value]
            return result if self.callback is None else self.callback(resu...
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/sensors/dataflow.py:485: error:
Incompatible return value type (got "list[dict[Any, Any]] | Any", expected
"bool")  [return-value]
            return result if self.callback is None else self.callback(resu...
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/consume.py:137: error:
"str" not callable  [operator]
                apply_callable = partial(
                                 ^
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/consume.py:144: error:
"str" not callable  [operator]
                apply_callable = partial(
                                 ^
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/produce.py:119: error:
"str" not callable  [operator]
            producer_callable = partial(
                                ^
providers/google/src/airflow/providers/google/cloud/triggers/bigquery.py:594: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "list[Any]")  [assignment]
                        records = records.pop(0) if records else None
                                  ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1106: error:
Unsupported left operand type for + ("None")  [operator]
            return self.project_id + ":" + self.location + ":" + self.inst...
                   ^~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1106: note: Left operand is of type "Any | None"
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1141: error:
Argument "project_id" to "CloudSqlProxyRunner" has incompatible type
"Any | None"; expected "str"  [arg-type]
                project_id=self.project_id,
                           ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:271: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:359: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:420: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:491: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/operators/bigquery.py:1163: error:
List comprehension has incompatible type List[Any | list[Any]]; expected
List[dict[str, Any]]  [misc]
                    table_data = [row.values() if isinstance(row, Row) els...

gopidesupavan · 2025-07-09T19:50:03Z

Provider mypy fixes required:

providers/elasticsearch/src/airflow/providers/elasticsearch/version_compat.py:48: error:
Incompatible types in assignment (expression has type
"type[list[tuple[str, str]]]", variable has type
"UnionType[list[StructuredLogMessage], str]")  [assignment]
        EsLogMsgType = list[tuple[str, str]]  # type: ignore[misc]
                       ^~~~~~~~~~~~~~~~~~~~~
providers/elasticsearch/src/airflow/providers/elasticsearch/version_compat.py:48: note: Error code "assignment" not covered by "type: ignore" comment
providers/edge3/src/airflow/providers/edge3/models/edge_worker.py:113: error:
Incompatible return value type (got "Any | None", expected "dict[Any, Any]") 
[return-value]
            return json.loads(self.sysinfo) if self.sysinfo else None
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py:105: error:
Argument 1 to "get_lb_policy" of "CassandraHook" has incompatible type
"Any | None"; expected "str"  [arg-type]
            lb_policy = self.get_lb_policy(policy_name, policy_args)
                                           ^~~~~~~~~~~
providers/keycloak/src/airflow/providers/keycloak/auth_manager/keycloak_auth_manager.py:211: error:
Redundant cast to "Literal['GET', 'POST', 'PUT', 'DELETE', 'MENU']" 
[redundant-cast]
                    (cast("ExtendedResourceMethod", "MENU"), menu_item.val...
                     ^
providers/http/src/airflow/providers/http/hooks/http.py:238: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "int")  [assignment]
            session.max_redirects = self.merged_extra.get("max_redirects",...
                                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/samba/src/airflow/providers/samba/hooks/samba.py:260: error: Missing
positional argument "path" in call to "__call__" of "_Wrapped"  [call-arg]
            with open(local_filepath, "rb") as f, self.open_file(destinati...
                                                  ^~~~~~~~~~~~~~~~~~~~~~~~...
providers/samba/src/airflow/providers/samba/hooks/samba.py:260: error: Argument
1 to "__call__" of "_Wrapped" has incompatible type "str"; expected "SambaHook" 
[arg-type]
    ... open(local_filepath, "rb") as f, self.open_file(destination_filepath,...
                                                        ^~~~~~~~~~~~~~~~~~~~
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/resource.py:111: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "dict[Any, Any]")  [assignment]
                metadata: dict = body.get("metadata", None)
                                 ^~~~~~~~~~~~~~~~~~~~~~~~~~
providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py:55: error:
Incompatible types in assignment (expression has type
"type[list[tuple[str, str]]]", variable has type
"UnionType[list[StructuredLogMessage], str]")  [assignment]
        OsLogMsgType = list[tuple[str, str]]  # type: ignore[misc]
                       ^~~~~~~~~~~~~~~~~~~~~
providers/opensearch/src/airflow/providers/opensearch/log/os_task_handler.py:55: note: Error code "assignment" not covered by "type: ignore" comment
providers/google/src/airflow/providers/google/cloud/links/kubernetes_engine.py:62: error:
Item "None" of "Any | None" has no attribute "name"  [union-attr]
                cluster_name=cluster.name,
                             ^~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:265: error:
Incompatible types in assignment (expression has type "int", variable has type
"VerificationStatus")  [assignment]
                    monitoring_v3.NotificationChannel.VerificationStatus.V...
                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:277: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    channel.name = None
                                   ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:287: error:
Incompatible types in assignment (expression has type "None", variable has type
"MutationRecord")  [assignment]
                policy.creation_record = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:288: error:
Incompatible types in assignment (expression has type "None", variable has type
"MutationRecord")  [assignment]
                policy.mutation_record = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:304: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    policy.name = None
                                  ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:306: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                        condition.name = None
                                         ^~~~
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:535: error:
Incompatible types in assignment (expression has type "int", variable has type
"VerificationStatus")  [assignment]
                    monitoring_v3.NotificationChannel.VerificationStatus.V...
                    ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
providers/google/src/airflow/providers/google/cloud/hooks/stackdriver.py:547: error:
Incompatible types in assignment (expression has type "None", variable has type
"str")  [assignment]
                    channel.name = None
                                   ^~~~
providers/samba/src/airflow/providers/samba/transfers/gcs_to_samba.py:200: error:
Missing positional argument "path" in call to "__call__" of "_Wrapped" 
[call-arg]
            samba_hook.makedirs(dir_path, exist_ok=True)
            ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/samba/src/airflow/providers/samba/transfers/gcs_to_samba.py:200: error:
Argument 1 to "__call__" of "_Wrapped" has incompatible type "str"; expected
"SambaHook"  [arg-type]
            samba_hook.makedirs(dir_path, exist_ok=True)
                                ^~~~~~~~
providers/google/src/airflow/providers/google/cloud/sensors/datafusion.py:135: error:
Unsupported operand types for in ("Any | None" and "Iterable[str]")  [operator]
            return pipeline_status in self.expected_statuses
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:108: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance], Any]") 
[misc]
            def on_task_instance_running(
            ^
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:260: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance | TaskInstance], None]")
 [misc]
            def on_task_instance_success(
            ^
providers/openlineage/src/airflow/providers/openlineage/plugins/listener.py:389: error:
Incompatible redefinition (redefinition with type
"Callable[[OpenLineageListener, TaskInstanceState, TaskInstance, str | BaseException | None, Any], None]",
original type
"Callable[[OpenLineageListener, TaskInstanceState, RuntimeTaskInstance | TaskInstance, str | BaseException | None], None]")
 [misc]
            def on_task_instance_failed(
            ^
providers/google/src/airflow/providers/google/cloud/sensors/dataflow.py:363: error:
Incompatible return value type (got "list[dict[Any, Any]] | Any", expected
"bool")  [return-value]
            return result if self.callback is None else self.callback(resu...
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/sensors/dataflow.py:485: error:
Incompatible return value type (got "list[dict[Any, Any]] | Any", expected
"bool")  [return-value]
            return result if self.callback is None else self.callback(resu...
                   ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/consume.py:137: error:
"str" not callable  [operator]
                apply_callable = partial(
                                 ^
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/consume.py:144: error:
"str" not callable  [operator]
                apply_callable = partial(
                                 ^
providers/apache/kafka/src/airflow/providers/apache/kafka/operators/produce.py:119: error:
"str" not callable  [operator]
            producer_callable = partial(
                                ^
providers/google/src/airflow/providers/google/cloud/triggers/bigquery.py:594: error:
Incompatible types in assignment (expression has type "Any | None", variable has
type "list[Any]")  [assignment]
                        records = records.pop(0) if records else None
                                  ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1106: error:
Unsupported left operand type for + ("None")  [operator]
            return self.project_id + ":" + self.location + ":" + self.inst...
                   ^~~~~~~~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1106: note: Left operand is of type "Any | None"
providers/google/src/airflow/providers/google/cloud/hooks/cloud_sql.py:1141: error:
Argument "project_id" to "CloudSqlProxyRunner" has incompatible type
"Any | None"; expected "str"  [arg-type]
                project_id=self.project_id,
                           ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:271: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:359: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:420: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/teradata/src/airflow/providers/teradata/operators/teradata_compute_cluster.py:491: error:
Call to abstract method "execute" of "_TeradataComputeClusterOperator" with
trivial body via super() is unsafe  [safe-super]
            super().execute(context)
            ^~~~~~~~~~~~~~~
providers/google/src/airflow/providers/google/cloud/operators/bigquery.py:1163: error:
List comprehension has incompatible type List[Any | list[Any]]; expected
List[dict[str, Any]]  [misc]
                    table_data = [row.values() if isinstance(row, Row) els...

cc: @jscheffl

gopidesupavan · 2025-07-11T16:49:24Z

cool We have mypy green :)

potiuk · 2025-07-11T17:56:29Z

Wooohooooo

gopidesupavan · 2025-07-11T18:41:27Z

merging failure not related

jscheffl · 2025-07-11T20:44:37Z

Wohoo!

* Bump mypy to 1.16.1 * Bump mypy to 1.16.1 and fix core mypy errors * Bump mypy to 1.16.1 and fix core mypy errors * Remove ParsedLog casting

gopidesupavan requested review from ashb, bolkedebruin, bugraoz93, ephraimbuddy, jason810496, pierrejeambrun, rawwar, shubhamraj-git and uranusjr as code owners July 7, 2025 22:11

boring-cyborg bot added area:API Airflow's REST/HTTP API area:serialization labels Jul 7, 2025

gopidesupavan commented Jul 7, 2025

View reviewed changes

airflow-core/src/airflow/serialization/serde.py Show resolved Hide resolved

gopidesupavan requested review from amoghrajesh and potiuk July 7, 2025 22:13

uranusjr mentioned this pull request Jul 8, 2025

Remove direct scheduler BaseOperator refs #52234

Merged

gopidesupavan changed the title ~~Bump mypy to 1.16.1 and fix mypy core errors~~ Bump mypy to 1.16.1 Jul 8, 2025

gopidesupavan requested a review from kaxil as a code owner July 8, 2025 21:38

gopidesupavan marked this pull request as draft July 8, 2025 21:39

gopidesupavan mentioned this pull request Jul 9, 2025

Bump mypy to 1.16.1 for airflow-core and fix airflow-core mypy errors #53004

Merged

gopidesupavan force-pushed the bump-mypy-core branch 2 times, most recently from 3586f2d to 620b4be Compare July 9, 2025 19:45

gopidesupavan mentioned this pull request Jul 9, 2025

Make edge3 provider compatible with mypy 1.16.1 #53104

Merged

gopidesupavan force-pushed the bump-mypy-core branch from 620b4be to 2f97fc6 Compare July 9, 2025 19:51

jscheffl mentioned this pull request Jul 9, 2025

Make http provider compatible with mypy 1.16.1 #53108

Merged

jscheffl mentioned this pull request Jul 9, 2025

Bugfix/fix mypy samba #53113

Merged

gopidesupavan mentioned this pull request Jul 9, 2025

Bugfix/return DataflowJobMessagesSensor and DataflowJobAutoScalingEventsSensor result with xcom_value #53115

Merged

jscheffl force-pushed the bump-mypy-core branch from 2f97fc6 to dde1729 Compare July 10, 2025 04:14

gopidesupavan force-pushed the bump-mypy-core branch from dde1729 to 29968fa Compare July 10, 2025 06:23

gopidesupavan force-pushed the bump-mypy-core branch from 29968fa to 4fa0d54 Compare July 10, 2025 16:37

gopidesupavan closed this Jul 10, 2025

gopidesupavan reopened this Jul 10, 2025

jscheffl force-pushed the bump-mypy-core branch from 4fa0d54 to 8c8b30b Compare July 10, 2025 18:41

gopidesupavan mentioned this pull request Jul 10, 2025

Make task-sdk compatible with mypy 1.16.1 #53047

Merged

gopidesupavan force-pushed the bump-mypy-core branch 2 times, most recently from e18ea61 to a89d84b Compare July 11, 2025 13:12

gopidesupavan marked this pull request as ready for review July 11, 2025 15:44

gopidesupavan added 4 commits July 11, 2025 17:23

Bump mypy to 1.16.1

8ce768b

Bump mypy to 1.16.1 and fix core mypy errors

4517bc2

Bump mypy to 1.16.1 and fix core mypy errors

40f9d3b

Remove ParsedLog casting

6d162e5

gopidesupavan force-pushed the bump-mypy-core branch from 69bcc84 to 6d162e5 Compare July 11, 2025 16:23

potiuk approved these changes Jul 11, 2025

View reviewed changes

gopidesupavan merged commit 67d6e4b into apache:main Jul 11, 2025
85 of 86 checks passed

stephen-bracken pushed a commit to stephen-bracken/airflow that referenced this pull request Jul 15, 2025

Bump mypy to 1.16.1 (apache#52997)

194ef4e

* Bump mypy to 1.16.1 * Bump mypy to 1.16.1 and fix core mypy errors * Bump mypy to 1.16.1 and fix core mypy errors * Remove ParsedLog casting

eladkal mentioned this pull request Jul 29, 2025

Status of testing Providers that were prepared on July 29, 2025 #53873

Closed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Bump mypy to 1.16.1 #52997

Bump mypy to 1.16.1 #52997

Uh oh!

gopidesupavan commented Jul 7, 2025

Uh oh!

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 11, 2025

Uh oh!

potiuk commented Jul 11, 2025

Uh oh!

gopidesupavan commented Jul 11, 2025

Uh oh!

Uh oh!

jscheffl commented Jul 11, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Bump mypy to 1.16.1 #52997

Bump mypy to 1.16.1 #52997

Uh oh!

Conversation

gopidesupavan commented Jul 7, 2025

Uh oh!

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 8, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 9, 2025

Uh oh!

gopidesupavan commented Jul 11, 2025

Uh oh!

potiuk commented Jul 11, 2025

Uh oh!

gopidesupavan commented Jul 11, 2025

Uh oh!

Uh oh!

jscheffl commented Jul 11, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants