From 76f116ed10d1a781c00301c0f421cb63357aeda2 Mon Sep 17 00:00:00 2001 From: Samapriya Roy Date: Sun, 1 Oct 2023 00:41:12 -0500 Subject: [PATCH] updated v1.0.1 - Updated pending/ready tasks as they are called in tasklist - Fixed task cancellation options --- docs/changelog.md | 4 ++++ geeadd/__init__.py | 2 +- geeadd/geeadd.py | 15 ++++++--------- setup.py | 2 +- 4 files changed, 12 insertions(+), 11 deletions(-) diff --git a/docs/changelog.md b/docs/changelog.md index faf190a..bda1c34 100644 --- a/docs/changelog.md +++ b/docs/changelog.md @@ -1,5 +1,9 @@ # Changelog +#### v1.0.1 +- Updated pending/ready tasks as they are called in tasklist +- Fixed task cancellation options + ### v1.0.0 - Gives better parsing of tasking info - Search by task ID now diff --git a/geeadd/__init__.py b/geeadd/__init__.py index 2f54ed4..0eb1fe8 100644 --- a/geeadd/__init__.py +++ b/geeadd/__init__.py @@ -2,4 +2,4 @@ __author__ = "Samapriya Roy" __email__ = "samapriya.roy@gmail.com" -__version__ = "1.0.0" +__version__ = "1.0.1" diff --git a/geeadd/geeadd.py b/geeadd/geeadd.py index b6061bc..ca2753f 100644 --- a/geeadd/geeadd.py +++ b/geeadd/geeadd.py @@ -143,7 +143,7 @@ def cancel_tasks(tasks): task for task in ee.data.listOperations() if task["metadata"]["state"] == "RUNNING" - or task["metadata"]["state"] == "PENDING" + or task["metadata"]["state"] == "READY" ] if len(all_tasks) > 0: for task in all_tasks: @@ -179,7 +179,7 @@ def cancel_tasks(tasks): ready_tasks = [ task for task in ee.data.listOperations() - if task["metadata"]["state"] == "PENDING" + if task["metadata"]["state"] == "READY" ] if len(ready_tasks) > 0: for task in ready_tasks: @@ -199,7 +199,7 @@ def cancel_tasks(tasks): ) if ( get_status["metadata"]["state"] == "RUNNING" - or get_status["metadata"]["state"] == "PENDING" + or get_status["metadata"]["state"] == "READY" ): ee.data.cancelTask(task["id"]) print( @@ -214,9 +214,6 @@ def cancel_tasks(tasks): def delete(ids): try: print("Recursively deleting path: {}".format(ids)) - # subprocess.call( - # "earthengine rm -r {}".format(ids), shell=True, stdout=subprocess.PIPE - # ) process_output = subprocess.run(["earthengine", "rm", "-r", "{}".format(ids)], capture_output=True, text=True) print("output from commandline: {}".format(process_output.stdout)) except Exception as e: @@ -334,7 +331,7 @@ def tasks(state,id): for status in statuses: st.append(status["state"]) print(f"Tasks Running: {st.count('RUNNING')}") - print(f"Tasks Pending: {st.count('PENDING')}") + print(f"Tasks Pending: {st.count('READY')}") print(f"Tasks Completed: {st.count('COMPLETED')+st.count('SUCCEEDED')}") print(f"Tasks Failed: {st.count('FAILED')}") print(f"Tasks Cancelled: {st.count('CANCELLED') + st.count('CANCELLING')}") @@ -703,12 +700,12 @@ def main(args=None): parser_tasks = subparsers.add_parser( "tasks", - help="Queries current task status [completed,running,pending,failed,cancelled]", + help="Queries current task status [completed,running,ready,failed,cancelled]", ) optional_named = parser_tasks.add_argument_group("Optional named arguments") optional_named.add_argument( "--state", - help="Query by state type COMPLETED|PENDING|RUNNING|FAILED", + help="Query by state type COMPLETED|READY|RUNNING|FAILED", ) optional_named.add_argument( "--id", diff --git a/setup.py b/setup.py index 99e0e9e..d126431 100644 --- a/setup.py +++ b/setup.py @@ -2,7 +2,7 @@ setup( name="geeadd", - version="1.0.0", + version="1.0.1", packages=["geeadd"], data_files=[("", ["LICENSE"])], url="https://github.com/samapriya/gee_asset_manager_addon",