Skip to content
This repository has been archived by the owner on Feb 3, 2021. It is now read-only.

Feature: 0.10.0 remove deprecated code #671

Merged
merged 5 commits into from
Oct 24, 2018
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 0 additions & 3 deletions aztk/client/base/helpers/get_task_state.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,8 @@

def get_task_state(core_cluster_operations, cluster_id: str, task_id: str):
try:
# TODO: return TaskState object instead of str
scheduling_target = core_cluster_operations.get_cluster_configuration(cluster_id).scheduling_target
if scheduling_target is not SchedulingTarget.Any:
# get storage table entry for this application
# convert entry to application_status
task = core_cluster_operations.get_task_from_table(cluster_id, task_id)
return task.state
else:
Expand Down
4 changes: 2 additions & 2 deletions aztk/client/base/helpers/list_tasks.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from aztk.models import SchedulingTarget, Task
from aztk.models import SchedulingTarget

from .get_recent_job import get_recent_job
from .task_table import list_task_table_entries
Expand All @@ -12,7 +12,7 @@ def list_tasks(core_base_operations, id):
Args:
id: cluster or job id
Returns:
List[aztk.models.Task]
List[aztk.models.Task]

"""
scheduling_target = core_base_operations.get_cluster_configuration(id).scheduling_target
Expand Down
3 changes: 1 addition & 2 deletions aztk/client/base/helpers/node_run.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
import aztk.error as error
import aztk.models as models
from aztk import error, models
from aztk.utils import ssh as ssh_lib


Expand Down
Loading