diff --git a/datapackage_pipelines/web/server.py b/datapackage_pipelines/web/server.py index af94b730..4a6ea094 100644 --- a/datapackage_pipelines/web/server.py +++ b/datapackage_pipelines/web/server.py @@ -105,11 +105,20 @@ def wrapper(*args, **kwargs): @blueprint.route("") +@blueprint.route("") @basic_auth_required -def main(): - all_pipeline_ids = sorted(status.all_pipeline_ids()) +def main(pipeline_path=None): + pipeline_ids = sorted(status.all_pipeline_ids()) + + # If we have a pipeline_path, filter the pipeline ids. + if pipeline_path is not None: + if not pipeline_path.startswith('./'): + pipeline_path = './' + pipeline_path + + pipeline_ids = [p for p in pipeline_ids if p.startswith(pipeline_path)] + statuses = [] - for pipeline_id in all_pipeline_ids: + for pipeline_id in pipeline_ids: pipeline_status = status.get(pipeline_id) ex = pipeline_status.get_last_execution() success_ex = pipeline_status.get_last_successful_execution() diff --git a/datapackage_pipelines/web/templates/dashboard.html b/datapackage_pipelines/web/templates/dashboard.html index 00d2d7ee..78ea128b 100644 --- a/datapackage_pipelines/web/templates/dashboard.html +++ b/datapackage_pipelines/web/templates/dashboard.html @@ -100,7 +100,7 @@
@@ -121,17 +121,22 @@