Skip to content

Commit

Permalink
clean up skip mode
Browse files Browse the repository at this point in the history
  • Loading branch information
wxtim committed Mar 28, 2024
1 parent 5b4df9c commit fb0e3d4
Showing 1 changed file with 4 additions and 22 deletions.
26 changes: 4 additions & 22 deletions cylc/flow/run_modes/skip.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,34 +16,17 @@
"""Utilities supporting simulation and skip modes
"""

from dataclasses import dataclass
from logging import INFO
from typing import (
TYPE_CHECKING, Any, Dict, List, Optional, Tuple, Union)
from time import time
TYPE_CHECKING, Any, Dict, Tuple)

from cylc.flow import LOG
from cylc.flow.cycling import PointBase
from cylc.flow.cycling.loader import get_point
from cylc.flow.exceptions import PointParsingError
from cylc.flow.platforms import FORBIDDEN_WITH_PLATFORM, get_platform
from cylc.flow.platforms import get_platform
from cylc.flow.task_outputs import TASK_OUTPUT_SUBMITTED
from cylc.flow.task_state import (
TASK_STATUS_RUNNING,
TASK_STATUS_FAILED,
TASK_STATUS_SUCCEEDED,
MODE_SKIP,
)
from cylc.flow.wallclock import get_unix_time_from_time_string

from metomi.isodatetime.parsers import DurationParser
from cylc.flow.task_state import MODE_SKIP

if TYPE_CHECKING:
from cylc.flow.task_events_mgr import TaskEventsManager
from cylc.flow.task_job_mgr import TaskJobManager
from cylc.flow.task_proxy import TaskProxy
from cylc.flow.workflow_db_mgr import WorkflowDatabaseManager
from typing import bool_value


def submit_task_job(
Expand All @@ -52,7 +35,7 @@ def submit_task_job(
rtconfig: Dict[str, Any],
workflow: str,
now: Tuple[float, str]
) -> 'bool_value[True]':
) -> 'bool':
"""Submit a task in simulation mode.
"""
itask.summary['started_time'] = now[0]
Expand All @@ -74,5 +57,4 @@ def submit_task_job(
'try_num': itask.get_try_num(),
}
)
itask.state.status = TASK_STATUS_RUNNING
return True

0 comments on commit fb0e3d4

Please sign in to comment.