This is an automated email from the ASF dual-hosted git repository.
amoghrajesh 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 e4b34471e46 Rename resumablemixin file to match class name (#68137)
e4b34471e46 is described below
commit e4b34471e461ae1a1df92cc96251b9b1fa1a2a08
Author: Amogh Desai <[email protected]>
AuthorDate: Sun Jun 7 06:56:44 2026 +0530
Rename resumablemixin file to match class name (#68137)
---
docs/spelling_wordlist.txt | 1 +
.../src/airflow/providers/apache/spark/operators/spark_submit.py | 2 +-
task-sdk/src/airflow/sdk/__init__.py | 4 ++--
task-sdk/src/airflow/sdk/__init__.pyi | 2 ++
.../src/airflow/sdk/bases/{resumablemixin.py => resumablejobmixin.py} | 0
task-sdk/tests/task_sdk/bases/test_resumablemixin.py | 2 +-
6 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/docs/spelling_wordlist.txt b/docs/spelling_wordlist.txt
index 00c557d1eb2..dac67989526 100644
--- a/docs/spelling_wordlist.txt
+++ b/docs/spelling_wordlist.txt
@@ -911,6 +911,7 @@ js
Json
json
jsonl
+JsonValue
juli
Jupyter
jupyter
diff --git
a/providers/apache/spark/src/airflow/providers/apache/spark/operators/spark_submit.py
b/providers/apache/spark/src/airflow/providers/apache/spark/operators/spark_submit.py
index 3ac4870f313..902d96a225b 100644
---
a/providers/apache/spark/src/airflow/providers/apache/spark/operators/spark_submit.py
+++
b/providers/apache/spark/src/airflow/providers/apache/spark/operators/spark_submit.py
@@ -31,7 +31,7 @@ from airflow.providers.common.compat.openlineage.utils.spark
import (
from airflow.providers.common.compat.sdk import BaseOperator, conf
try:
- from airflow.sdk.bases.resumablemixin import ResumableJobMixin
+ from airflow.sdk import ResumableJobMixin
except ImportError:
# Airflow 2 compat.
# ResumableJobMixin does not exist in Airflow 2, so we need to add a stub
to make it
diff --git a/task-sdk/src/airflow/sdk/__init__.py
b/task-sdk/src/airflow/sdk/__init__.py
index 3faefd2ce3c..b922cad9e1f 100644
--- a/task-sdk/src/airflow/sdk/__init__.py
+++ b/task-sdk/src/airflow/sdk/__init__.py
@@ -126,7 +126,7 @@ if TYPE_CHECKING:
cross_downstream,
)
from airflow.sdk.bases.operatorlink import BaseOperatorLink
- from airflow.sdk.bases.resumablemixin import ResumableJobMixin
+ from airflow.sdk.bases.resumablejobmixin import ResumableJobMixin
from airflow.sdk.bases.sensor import BaseSensorOperator, PokeReturnValue
from airflow.sdk.bases.skipmixin import SkipMixin
from airflow.sdk.bases.xcom import BaseXCom
@@ -256,7 +256,7 @@ __lazy_imports: dict[str, str] = {
"PokeReturnValue": ".bases.sensor",
"ProductMapper": ".definitions.partition_mappers.product",
"QuarterWindow": ".definitions.partition_mappers.window",
- "ResumableJobMixin": ".bases.resumablemixin",
+ "ResumableJobMixin": ".bases.resumablejobmixin",
"RetryAction": ".definitions.retry_policy",
"RetryDecision": ".definitions.retry_policy",
"RetryPolicy": ".definitions.retry_policy",
diff --git a/task-sdk/src/airflow/sdk/__init__.pyi
b/task-sdk/src/airflow/sdk/__init__.pyi
index 8acb18026b1..703e3d4f0e6 100644
--- a/task-sdk/src/airflow/sdk/__init__.pyi
+++ b/task-sdk/src/airflow/sdk/__init__.pyi
@@ -35,6 +35,7 @@ from airflow.sdk.bases.operator import (
cross_downstream as cross_downstream,
)
from airflow.sdk.bases.operatorlink import BaseOperatorLink as BaseOperatorLink
+from airflow.sdk.bases.resumablejobmixin import ResumableJobMixin as
ResumableJobMixin
from airflow.sdk.bases.sensor import (
BaseSensorOperator as BaseSensorOperator,
PokeReturnValue as PokeReturnValue,
@@ -169,6 +170,7 @@ __all__ = [
"RetryDecision",
"RetryPolicy",
"RetryRule",
+ "ResumableJobMixin",
"RollupMapper",
"SecretCache",
"SkipMixin",
diff --git a/task-sdk/src/airflow/sdk/bases/resumablemixin.py
b/task-sdk/src/airflow/sdk/bases/resumablejobmixin.py
similarity index 100%
rename from task-sdk/src/airflow/sdk/bases/resumablemixin.py
rename to task-sdk/src/airflow/sdk/bases/resumablejobmixin.py
diff --git a/task-sdk/tests/task_sdk/bases/test_resumablemixin.py
b/task-sdk/tests/task_sdk/bases/test_resumablemixin.py
index 9e28a53d31d..999d041f07a 100644
--- a/task-sdk/tests/task_sdk/bases/test_resumablemixin.py
+++ b/task-sdk/tests/task_sdk/bases/test_resumablemixin.py
@@ -20,8 +20,8 @@ from typing import TYPE_CHECKING
import pytest
+from airflow.sdk import ResumableJobMixin
from airflow.sdk.bases.operator import BaseOperator
-from airflow.sdk.bases.resumablemixin import ResumableJobMixin
if TYPE_CHECKING:
from pydantic import JsonValue
