Revert "support cache task (#50)"

This reverts commit cf62349.

Author: zhongjiajie

examples/yaml_define/MoreConfiguration.yaml

@@ -36,7 +36,6 @@ tasks:
     fail_retry_times: 30
     fail_retry_interval: 5
     timeout: 60
-    is_cache: true
     input_params:
       value_VARCHAR: "abc"
       value_INTEGER: 123

src/pydolphinscheduler/constants.py

@@ -35,13 +35,6 @@ class TaskFlag(str):
     NO = "NO"
 
 
-class IsCache(str):
-    """Constants for Cache."""
-
-    YES = "YES"
-    NO = "NO"
-
-
 class TaskTimeoutFlag(str):
     """Constants for task timeout flag."""
 

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 @@ class Task(Base):
     :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 @@ class Task(Base):
         "timeout_flag",
         "timeout_notify_strategy",
         "timeout",
-        "is_cache",
     }
 
     # task default attribute will into `task_params` property
@@ -164,7 +161,6 @@ def __init__(
         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 @@ def __init__(
         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
@@ -251,14 +246,6 @@ def timeout_flag(self) -> str:
         """Whether the timeout attribute is being set or not."""
         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`."""

tests/core/test_engine.py

@@ -122,7 +122,6 @@ def test_property_task_params(mock_resource, mock_code_version, attr, expect):
                     "waitStartTimeout": {},
                 },
                 "flag": "YES",
-                "isCache": "NO",
                 "taskPriority": "MEDIUM",
                 "workerGroup": "default",
                 "environmentCode": None,

tests/core/test_task.py

@@ -252,7 +252,6 @@ def test_task_get_define():
             "waitStartTimeout": {},
         },
         "flag": "YES",
-        "isCache": "NO",
         "taskPriority": "MEDIUM",
         "workerGroup": "default",
         "environmentCode": None,