quaint-barista-82836
02/08/2023, 3:46 AMCalculating Metrics: 0%| | 0/15 [00:00<?, ?it/s]
Calculating Metrics: 0%| | 0/15 [00:00<?, ?it/s]
Calculating Metrics: 13%|█▎ | 2/15 [00:00<00:01, 12.15it/s]
Calculating Metrics: 13%|█▎ | 2/15 [00:00<00:01, 12.15it/s]
Calculating Metrics: 13%|█▎ | 2/15 [00:00<00:01, 12.15it/s]
Calculating Metrics: 27%|██▋ | 4/15 [00:02<00:08, 1.34it/s]
Calculating Metrics: 27%|██▋ | 4/15 [00:02<00:08, 1.34it/s]
Calculating Metrics: 27%|██▋ | 4/15 [00:02<00:08, 1.34it/s]
Calculating Metrics: 47%|████▋ | 7/15 [00:02<00:05, 1.34it/s]
Calculating Metrics: 47%|████▋ | 7/15 [00:02<00:05, 1.34it/s]
Calculating Metrics: 80%|████████ | 12/15 [00:05<00:01, 2.14it/s]
Calculating Metrics: 80%|████████ | 12/15 [00:05<00:01, 2.14it/s]
Calculating Metrics: 80%|████████ | 12/15 [00:05<00:01, 2.14it/s]
Calculating Metrics: 100%|██████████| 15/15 [00:07<00:00, 1.86it/s]
Calculating Metrics: 100%|██████████| 15/15 [00:07<00:00, 1.86it/s]
Calculating Metrics: 100%|██████████| 15/15 [00:07<00:00, 1.86it/s]
Calculating Metrics: 100%|██████████| 15/15 [00:07<00:00, 1.86it/s]
Calculating Metrics: 100%|██████████| 15/15 [00:07<00:00, 1.93it/s]
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Finding datasets being validated
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Datasource my_bigquery_datasource is not present in platform_instance_map
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - GE expectation_suite_name - demo, expectation_type - expect_column_values_to_not_be_null, Assertion URN - urn:li:assertion:6f56acc887e38af0561eaeb8d41b0bdb
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - GE expectation_suite_name - demo, expectation_type - expect_column_values_to_be_between, Assertion URN - urn:li:assertion:aa04dc0fc98f145d01ae9fcd5f7f4ee3
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Sending metadata to datahub ...
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Dataset URN - urn:li:dataset:(urn:li:dataPlatform:bigquery,project.dataset.fbt_diff,PROD)
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Assertion URN - urn:li:assertion:6f56acc887e38af0561eaeb8d41b0bdb
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Assertion URN - urn:li:assertion:aa04dc0fc98f145d01ae9fcd5f7f4ee3
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Metadata sent to datahub.
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Validation succeeded!
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO -
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - Suite Name Status Expectations met
[2023-02-08, 01:07:57 EST] {subprocess.py:89} INFO - - demo ✔ Passed 2 of 2 (100.0 %)
[2023-02-08, 01:07:59 EST] {subprocess.py:93} INFO - Command exited with return code 0
passing Datasource my_bigquery_datasource is not present in platform_instance_map value as :
action_list:
- name: store_validation_result
action:
class_name: StoreValidationResultAction
- name: store_evaluation_params
action:
class_name: StoreEvaluationParametersAction
- name: update_data_docs
action:
class_name: UpdateDataDocsAction
site_names: []
- name: datahub_action
action:
module_name: datahub.integrations.great_expectations.action
class_name: DataHubValidationAction
server_url: <http://ip_address:8080>
platform_instance_map:
datasource_name: my_bigquery_datasource
parse_table_names_from_sql: truehundreds-photographer-13496
02/08/2023, 7:48 AMconvert_urns_to_lowercase: Truequaint-barista-82836
02/08/2023, 3:22 PMurn:li:dataset:(urn:li:dataPlatform:bigquery,lowercase_project_name.FBT.fbt_diff,PROD)
Also if I re-ingest the metadata in bigquery, with convert_urns_to_lowercase: True, will it overwrite existing urns or make a new entry ?quaint-barista-82836
02/08/2023, 5:35 PMastonishing-answer-96712
02/08/2023, 5:59 PMquaint-barista-82836
02/08/2023, 6:44 PMhundreds-photographer-13496
02/09/2023, 5:55 AMif I re-ingest the metadata in bigquery, with convert_urns_to_lowercase: True, will it overwrite existing urns or make a new entry ?The ingestion with that
convert_urns_to_lowercase changed, would create new URNS(and so new dataset). The old dataset (with old URN) will have to be deleted. If you were using stateful ingestion in recipe, delete will happen automatically.
Hi @hundreds-photographer-13496 and Team any other suggestions, looks like the datahub lowercase complete urn and GX does onky tablename from urn which makes them incompatibleThis looks like an issue. Can you please create a github issue mentioning the Dataset URN from GX and Bigquery Dataset URN with and without using
convert_urns_to_lowercase: True ?quaint-barista-82836
02/09/2023, 3:52 PMif I re-ingest the metadata in bigquery, with convert_urns_to_lowercase: True, will it overwrite existing urns or make a new entry ?The ingestion with that
convert_urns_to_lowercase changed, would create new URNS(and so new dataset). The old dataset (with old URN) will have to be deleted. If you were using stateful ingestion in recipe, delete will happen automatically.
This has created 2 records on datahub with "stateful_ingestion":{"enabled": True },quaint-barista-82836
02/09/2023, 3:59 PMquaint-barista-82836
02/10/2023, 3:02 PMhundreds-photographer-13496
02/14/2023, 10:35 AMpipeline_name config) runs again and the dataset from last run is not seen, ingestion soft-deletes that dataset.
In case you are not able to get this to work using stateful ingestion, you can start bigquery ingestion afresh by soft deleting bigquery datasets (data is not permanently deleted, just marked as removed) using datahub cli command. datahub delete --platform bigquery --soft
and then run bigquery ingestion again to surface only the required datasets.quaint-barista-82836
02/28/2023, 9:22 PMhundreds-photographer-13496
03/02/2023, 10:03 AM