Skip to content

Commit

Permalink
Remove metadata command
Browse files Browse the repository at this point in the history
  • Loading branch information
arhall0 committed Dec 20, 2024
1 parent 4296dac commit 5d6a657
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 39 deletions.
19 changes: 0 additions & 19 deletions beeflow/client/bee_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -515,25 +515,6 @@ def query(wf_id: str = typer.Argument(..., callback=match_short_id)):
return wf_status, tasks_status


@app.command()
def metadata(wf_id: str = typer.Argument(..., callback=match_short_id)):
"""Get metadata about a given workflow."""
try:
conn = _wfm_conn()
resp = conn.get(_resource(wf_id) + '/metadata', timeout=60)
except requests.exceptions.ConnectionError:
error_exit('Could not reach WF Manager.')

if resp.status_code != requests.codes.okay: # noqa (pylama doesn't know about the okay member)
error_exit('Could not successfully query workflow manager')

# Print and or return the metadata
data = resp.json()
for key, value in data.items():
typer.echo(f'{key} = {value}')
return data


@app.command()
def pause(wf_id: str = typer.Argument(..., callback=match_short_id)):
"""Pause a workflow (Running tasks will finish)."""
Expand Down
18 changes: 0 additions & 18 deletions beeflow/wf_manager/resources/wf_metadata.py

This file was deleted.

2 changes: 0 additions & 2 deletions beeflow/wf_manager/wf_manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
from beeflow.common import paths
from beeflow.wf_manager.resources.wf_list import WFList
from beeflow.wf_manager.resources.wf_actions import WFActions
from beeflow.wf_manager.resources.wf_metadata import WFMetadata
from beeflow.wf_manager.resources.wf_update import WFUpdate
from beeflow.wf_manager.resources import wf_utils

Expand All @@ -21,7 +20,6 @@ def create_app():
# Add endpoints
api.add_resource(WFList, '/bee_wfm/v1/jobs/')
api.add_resource(WFActions, '/bee_wfm/v1/jobs/<string:wf_id>')
api.add_resource(WFMetadata, '/bee_wfm/v1/jobs/<string:wf_id>/metadata')
api.add_resource(WFUpdate, '/bee_wfm/v1/jobs/update/')

# Initialize celery app
Expand Down

0 comments on commit 5d6a657

Please sign in to comment.