Revert "support cache task (#50)"
This reverts commit cf623496449219a3134f82de62c452bc30fe1d22.
diff --git a/examples/yaml_define/MoreConfiguration.yaml b/examples/yaml_define/MoreConfiguration.yaml
index 849ee4b..0cda5ed 100644
--- a/examples/yaml_define/MoreConfiguration.yaml
+++ b/examples/yaml_define/MoreConfiguration.yaml
@@ -36,7 +36,6 @@
fail_retry_times: 30
fail_retry_interval: 5
timeout: 60
- is_cache: true
input_params:
value_VARCHAR: "abc"
value_INTEGER: 123
diff --git a/src/pydolphinscheduler/constants.py b/src/pydolphinscheduler/constants.py
index b28d3b6..1a5e11f 100644
--- a/src/pydolphinscheduler/constants.py
+++ b/src/pydolphinscheduler/constants.py
@@ -35,13 +35,6 @@
NO = "NO"
-class IsCache(str):
- """Constants for Cache."""
-
- YES = "YES"
- NO = "NO"
-
-
class TaskTimeoutFlag(str):
"""Constants for task timeout flag."""
diff --git a/src/pydolphinscheduler/core/task.py b/src/pydolphinscheduler/core/task.py
index 3341040..c4a0531 100644
--- a/src/pydolphinscheduler/core/task.py
+++ b/src/pydolphinscheduler/core/task.py
@@ -26,7 +26,6 @@
from pydolphinscheduler import configuration
from pydolphinscheduler.constants import (
Delimiter,
- IsCache,
ResourceKey,
Symbol,
TaskFlag,
@@ -101,7 +100,6 @@
:param wait_start_timeout: default None
:param condition_result: default None,
:param resource_plugin: default None
- :param is_cache: default False
:param input_params: default None, input parameters, {param_name: param_value}
:param output_params: default None, input parameters, {param_name: param_value}
"""
@@ -123,7 +121,6 @@
"timeout_flag",
"timeout_notify_strategy",
"timeout",
- "is_cache",
}
# task default attribute will into `task_params` property
@@ -164,7 +161,6 @@
wait_start_timeout: Optional[Dict] = None,
condition_result: Optional[Dict] = None,
resource_plugin: Optional[ResourcePlugin] = None,
- is_cache: Optional[bool] = False,
input_params: Optional[Dict] = None,
output_params: Optional[Dict] = None,
*args,
@@ -173,7 +169,6 @@
super().__init__(name, description)
self.task_type = task_type
self.flag = flag
- self._is_cache = is_cache
self.task_priority = task_priority
self.worker_group = worker_group
self._environment_name = environment_name
@@ -252,14 +247,6 @@
return TaskTimeoutFlag.ON if self._timeout else TaskTimeoutFlag.OFF
@property
- def is_cache(self) -> str:
- """Whether the cache is being set or not."""
- if isinstance(self._is_cache, bool):
- return IsCache.YES if self._is_cache else IsCache.NO
- else:
- raise PyDSParamException("is_cache must be a bool")
-
- @property
def resource_list(self) -> List[Dict[str, Resource]]:
"""Get task define attribute `resource_list`."""
resources = set()
diff --git a/tests/core/test_engine.py b/tests/core/test_engine.py
index 90a14d0..ba44fad 100644
--- a/tests/core/test_engine.py
+++ b/tests/core/test_engine.py
@@ -122,7 +122,6 @@
"waitStartTimeout": {},
},
"flag": "YES",
- "isCache": "NO",
"taskPriority": "MEDIUM",
"workerGroup": "default",
"environmentCode": None,
diff --git a/tests/core/test_task.py b/tests/core/test_task.py
index d34b6d2..d7aeb81 100644
--- a/tests/core/test_task.py
+++ b/tests/core/test_task.py
@@ -252,7 +252,6 @@
"waitStartTimeout": {},
},
"flag": "YES",
- "isCache": "NO",
"taskPriority": "MEDIUM",
"workerGroup": "default",
"environmentCode": None,
