diff --git a/beeflow/client/bee_client.py b/beeflow/client/bee_client.py index e3f8cafb..50ca17a9 100644 --- a/beeflow/client/bee_client.py +++ b/beeflow/client/bee_client.py @@ -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).""" diff --git a/beeflow/wf_manager/resources/wf_metadata.py b/beeflow/wf_manager/resources/wf_metadata.py deleted file mode 100644 index 4e7872a5..00000000 --- a/beeflow/wf_manager/resources/wf_metadata.py +++ /dev/null @@ -1,18 +0,0 @@ -"""Workflow endpoints for getting metadata.""" - -from flask import make_response, jsonify -from flask_restful import Resource -from beeflow.wf_manager.common import wf_db - - -class WFMetadata(Resource): - """Class for getting metadata.""" - - def get(self, wf_id): - """Get and return metadata.""" - # For now, just get the bolt port. Later we may want to add more information here. - bolt_port = wf_db.get_bolt_port(wf_id) - metadata = { - 'bolt_port': bolt_port, - } - return make_response(jsonify(metadata), 200) diff --git a/beeflow/wf_manager/wf_manager.py b/beeflow/wf_manager/wf_manager.py index 8134955a..d55e28c1 100644 --- a/beeflow/wf_manager/wf_manager.py +++ b/beeflow/wf_manager/wf_manager.py @@ -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 @@ -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/') - api.add_resource(WFMetadata, '/bee_wfm/v1/jobs//metadata') api.add_resource(WFUpdate, '/bee_wfm/v1/jobs/update/') # Initialize celery app