Add tasks.py

shipyard_airflow/control/api.py

@@ -16,6 +16,7 @@ import json
 
 from .regions import RegionsResource, RegionResource
 from .base import ShipyardRequest, BaseResource
+from .tasks import TaskResource
 
 from .middleware import AuthMiddleware, ContextMiddleware, LoggingMiddleware
 
@@ -30,10 +31,11 @@ def start_api():
         # API for managing region data
         ('/regions', RegionsResource()),
         ('/regions/{region_id}', RegionResource()),
+        ('/dags/{dag_id}/tasks/{task_id}', TaskResource()),
     ]
 
     for path, res in v1_0_routes:
-        control_api.add_route('/api/v1.0' + path, res)
+        control_api.add_route('/api/experimental' + path, res)
 
     return control_api
 

shipyard_airflow/control/tasks.py

@@ -0,0 +1,26 @@
+# Copyright 2017 AT&T Intellectual Property.  All other rights reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+import falcon
+import requests
+
+from .base import BaseResource
+
+class TaskResource(BaseResource):
+
+    authorized_roles = ['user']
+
+    def on_get(self, req, resp, dag_id, task_id):
+        resp.status = falcon.HTTP_200
+        req_url = 'http://localhost:32080/api/experimental/dags/' + dag_id + '/tasks/' + task_id
+        task_details = requests.get(req_url).json()