add pipeline data view

server/website/website/templates/pipeline_data.html

@@ -0,0 +1,43 @@
+{% extends "base.html" %}
+
+{% block body %}
+
+<div class="container">
+<table class="table table-striped table-bordered table-condensed table-hover">
+    <caption><h4 style="text-align: center;">Pipeline Data Info</h4></caption>
+    <tbody>
+    <tr>
+        <td style="width: 50%"><div class="text-right">ID:</div></td>
+        <td style="width: 50%">{{ id }}</td>
+    </tr>
+    <tr>
+        <td><div class="text-right">Creation Time:</div></td>
+        <td>{{ creation_time }}</td>
+    </tr>
+    <tr>
+        <td><div class="text-right">Task Name:</div></td>
+        <td>{{ task_name }}</td>
+    </tr>
+    <tr>
+        <td><div class="text-right">Workload:</div></td>
+        <td>{{ workload }}</td>
+    </tr>
+    </tbody>
+</table>
+</div>
+
+<div class="container">
+<table class="table table-striped table-bordered table-condensed table-hover">
+    <caption><h4 style="text-align: center;">{{ task_name }}</h4></caption>
+    <tbody>
+    {% for element in data %}
+        <tr>
+            <td style="width: 50%"><div class="text-right">{{forloop.counter}}</div></td>
+            <td style="width: 50%">{{ element }} </td>
+        </tr>
+    {% endfor %}
+    </tbody>
+</table>
+</div>
+
+{% endblock body %}

server/website/website/urls.py

@@ -80,7 +80,10 @@ urlpatterns = [
 
     # Test
     url(r'^test/create/', website_views.create_test_website, name='create_test_website'),
-    url(r'^test/pipeline/', website_views.pipeline_data_ready, name='pipeline_data_ready')
+    url(r'^test/pipeline/', website_views.pipeline_data_ready, name='pipeline_data_ready'),
+
+    # Pipeline data
+    url(r'^pipeline/data/(?P<pipeline_id>[0-9]+)', website_views.pipeline_data_view, name='pipeline_data_view')
 ]
 
 if settings.DEBUG:

server/website/website/views.py

@@ -42,10 +42,10 @@ from .db import parser, target_objectives
 from .forms import NewResultForm, ProjectForm, SessionForm, SessionKnobForm
 from .models import (BackupData, DBMSCatalog, ExecutionTime, Hardware, KnobCatalog, KnobData,
                      MetricCatalog, MetricData, PipelineRun, Project, Result, Session,
-                     SessionKnob, User, Workload)
+                     SessionKnob, User, Workload, PipelineData)
 from .tasks import train_ddpg
 from .types import (DBMSType, KnobUnitType, MetricType,
-                    TaskType, VarType, WorkloadStatusType, AlgorithmType)
+                    TaskType, VarType, WorkloadStatusType, AlgorithmType, PipelineTaskType)
 from .utils import (JSONUtil, LabelUtil, MediaUtil, TaskUtil)
 from .settings import LOG_DIR, TIME_ZONE, CHECK_CELERY
 
@@ -949,6 +949,19 @@ def download_debug_info(request, project_id, session_id):  # pylint: disable=unu
     return response
 
 
+@login_required(login_url=reverse_lazy('login'))
+def pipeline_data_view(request, pipeline_id):
+    pipeline_data = PipelineData.objects.get(pk=pipeline_id)
+    task_name = PipelineTaskType.TYPE_NAMES[pipeline_data.task_type]
+    data = JSONUtil.loads(pipeline_data.data)
+    context = {"id": pipeline_id,
+               "workload": pipeline_data.workload,
+               "creation_time": pipeline_data.creation_time,
+               "task_name": task_name,
+               "data": data}
+    return render(request, "pipeline_data.html", context)
+
+
 @login_required(login_url=reverse_lazy('login'))
 def tuner_status_view(request, project_id, session_id, result_id):  # pylint: disable=unused-argument
     res = Result.objects.get(pk=result_id)