feng-tao closed pull request #3903: [AIRFLOW-3067] Display www_rbac Flask flash msg properly URL: https://github.com/apache/incubator-airflow/pull/3903
This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/airflow/www_rbac/static/css/bootstrap-theme.css b/airflow/www_rbac/static/css/bootstrap-theme.css index 734f940fee..3adaec1d3b 100644 --- a/airflow/www_rbac/static/css/bootstrap-theme.css +++ b/airflow/www_rbac/static/css/bootstrap-theme.css @@ -4949,6 +4949,28 @@ a.thumbnail.active { .alert-danger .alert-link { color: #843534; } +.alert-message { + background-color: #d9edf7; + border-color: #bce8f1; + color: #31708f; +} +.alert-message hr { + border-top-color: #a6e1ec; +} +.alert-message .alert-link { + color: #245269; +} +.alert-error { + background-color: #f2dede; + border-color: #ebccd1; + color: #a94442; +} +.alert-error hr { + border-top-color: #e4b9c0; +} +.alert-error .alert-link { + color: #843534; +} @-webkit-keyframes progress-bar-stripes { from { background-position: 40px 0; diff --git a/airflow/www_rbac/views.py b/airflow/www_rbac/views.py index 3dc3400968..0fc3d67a80 100644 --- a/airflow/www_rbac/views.py +++ b/airflow/www_rbac/views.py @@ -782,11 +782,12 @@ def delete(self): try: delete_dag.delete_dag(dag_id) except DagNotFound: - flash("DAG with id {} not found. Cannot delete".format(dag_id)) + flash("DAG with id {} not found. Cannot delete".format(dag_id), 'error') return redirect(request.referrer) except DagFileExists: flash("Dag id {} is still in DagBag. " - "Remove the DAG file first.".format(dag_id)) + "Remove the DAG file first.".format(dag_id), + 'error') return redirect(request.referrer) flash("Deleting DAG with id {}. May take a couple minutes to fully" @@ -2065,7 +2066,7 @@ def varimport(self): else: d = json.loads(out) except Exception: - flash("Missing file or syntax error.") + flash("Missing file or syntax error.", 'error') else: suc_count = fail_count = 0 for k, v in d.items(): @@ -2076,7 +2077,7 @@ def varimport(self): fail_count += 1 else: suc_count += 1 - flash("{} variable(s) successfully updated.".format(suc_count), 'info') + flash("{} variable(s) successfully updated.".format(suc_count)) if fail_count: flash("{} variables(s) failed to be updated.".format(fail_count), 'error') self.update_redirect() @@ -2166,10 +2167,9 @@ def action_set_running(self, drs, session=None): dr.state = State.RUNNING models.DagStat.update(dirty_ids, session=session) session.commit() - flash( - "{count} dag runs were set to running".format(**locals())) + flash("{count} dag runs were set to running".format(**locals())) except Exception as ex: - flash(str(ex)) + flash(str(ex), 'error') flash('Failed to set state', 'error') return redirect(self.route_base + '/list') ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services