Repository: incubator-airflow Updated Branches: refs/heads/master 477944c96 -> 9aa7da501
[AIRFLOW-407] Add different colors for some sensors These colors were added (leftmost is the default sensor color): https://cloud.githubusercontent.com/assets/130362/17538403/e57502e4-5e59-11e6-9a65-80134d1e77af.png - Create a DAG with all these operators and take a screenshot Closes #1718 from zodiac/xuanji/add_colours_to_sensors Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/9aa7da50 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/9aa7da50 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/9aa7da50 Branch: refs/heads/master Commit: 9aa7da501373ecaba2485f21ed644036669596a0 Parents: 477944c Author: Li Xuanji <xua...@gmail.com> Authored: Wed Aug 10 20:59:45 2016 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Wed Aug 10 20:59:49 2016 -0700 ---------------------------------------------------------------------- airflow/contrib/operators/fs_operator.py | 1 + airflow/contrib/sensors/emr_base_sensor.py | 1 + airflow/operators/sensors.py | 6 ++++++ 3 files changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/9aa7da50/airflow/contrib/operators/fs_operator.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/operators/fs_operator.py b/airflow/contrib/operators/fs_operator.py index f89564c..2596487 100644 --- a/airflow/contrib/operators/fs_operator.py +++ b/airflow/contrib/operators/fs_operator.py @@ -33,6 +33,7 @@ class FileSensor(BaseSensorOperator): :type fs_conn_id: string """ template_fields = ('filepath',) + ui_color = '#91818a' @apply_defaults def __init__( http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/9aa7da50/airflow/contrib/sensors/emr_base_sensor.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/sensors/emr_base_sensor.py b/airflow/contrib/sensors/emr_base_sensor.py index c5dd1ca..5526604 100644 --- a/airflow/contrib/sensors/emr_base_sensor.py +++ b/airflow/contrib/sensors/emr_base_sensor.py @@ -25,6 +25,7 @@ class EmrBaseSensor(BaseSensorOperator): Subclasses should implement get_emr_response() and state_from_response() methods. Subclasses should also implment NON_TERMINAL_STATES and FAILED_STATE constants. """ + ui_color = '#66c3ff' @apply_defaults def __init__( http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/9aa7da50/airflow/operators/sensors.py ---------------------------------------------------------------------- diff --git a/airflow/operators/sensors.py b/airflow/operators/sensors.py index 467c468..570b682 100644 --- a/airflow/operators/sensors.py +++ b/airflow/operators/sensors.py @@ -92,6 +92,7 @@ class SqlSensor(BaseSensorOperator): """ template_fields = ('sql',) template_ext = ('.hql', '.sql',) + ui_color = '#7c7287' @apply_defaults def __init__(self, conn_id, sql, *args, **kwargs): @@ -135,6 +136,7 @@ class MetastorePartitionSensor(SqlSensor): :type mysql_conn_id: str """ template_fields = ('partition_name', 'table', 'schema') + ui_color = '#8da7be' @apply_defaults def __init__( @@ -190,6 +192,7 @@ class ExternalTaskSensor(BaseSensorOperator): or execution_date_fn can be passed to ExternalTaskSensor, but not both. :type execution_date_fn: callable """ + ui_color = '#19647e' @apply_defaults def __init__( @@ -257,6 +260,7 @@ class NamedHivePartitionSensor(BaseSensorOperator): """ template_fields = ('partition_names', ) + ui_color = '#8d99ae' @apply_defaults def __init__( @@ -330,6 +334,7 @@ class HivePartitionSensor(BaseSensorOperator): :type metastore_conn_id: str """ template_fields = ('schema', 'table', 'partition',) + ui_color = '#2b2d42' @apply_defaults def __init__( @@ -366,6 +371,7 @@ class HdfsSensor(BaseSensorOperator): Waits for a file or folder to land in HDFS """ template_fields = ('filepath',) + ui_color = '#4d9de0' @apply_defaults def __init__(