diff --git a/example/dags/hive_sample_dag.py b/example/dags/hive_sample_dag.py index 44143932b..ee86db9cb 100644 --- a/example/dags/hive_sample_dag.py +++ b/example/dags/hive_sample_dag.py @@ -163,6 +163,8 @@ def create_table_metadata_databuilder_job(): neo4j_password, 'publisher.neo4j.{}'.format(neo4j_csv_publisher.NEO4J_CREATE_ONLY_NODES): [DESCRIPTION_NODE_LABEL], + 'publisher.neo4j.job_publish_tag': + 'some_unique_tag' # TO-DO unique tag must be added }) job = DefaultJob(conf=job_config,