2727def lookup_bigquery_dataset (project_id , dataset_id ):
2828 # [START datacatalog_lookup_dataset]
2929 """Retrieves Data Catalog entry for the given BigQuery Dataset."""
30- from google .cloud import datacatalog_v1beta1
30+ from google .cloud import datacatalog_v1
3131
32- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
32+ datacatalog = datacatalog_v1 .DataCatalogClient ()
3333
3434 resource_name = '//bigquery.googleapis.com/projects/{}/datasets/{}' \
3535 .format (project_id , dataset_id )
@@ -42,9 +42,9 @@ def lookup_bigquery_dataset_sql_resource(project_id, dataset_id):
4242 """Retrieves Data Catalog entry for the given BigQuery Dataset by
4343 sql_resource.
4444 """
45- from google .cloud import datacatalog_v1beta1
45+ from google .cloud import datacatalog_v1
4646
47- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
47+ datacatalog = datacatalog_v1 .DataCatalogClient ()
4848
4949 sql_resource = 'bigquery.dataset.`{}`.`{}`' .format (project_id , dataset_id )
5050
@@ -53,9 +53,9 @@ def lookup_bigquery_dataset_sql_resource(project_id, dataset_id):
5353
5454def lookup_bigquery_table (project_id , dataset_id , table_id ):
5555 """Retrieves Data Catalog entry for the given BigQuery Table."""
56- from google .cloud import datacatalog_v1beta1
56+ from google .cloud import datacatalog_v1
5757
58- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
58+ datacatalog = datacatalog_v1 .DataCatalogClient ()
5959
6060 resource_name = '//bigquery.googleapis.com/projects/{}/datasets/{}' \
6161 '/tables/{}' \
@@ -68,9 +68,9 @@ def lookup_bigquery_table_sql_resource(project_id, dataset_id, table_id):
6868 """Retrieves Data Catalog entry for the given BigQuery Table by
6969 sql_resource.
7070 """
71- from google .cloud import datacatalog_v1beta1
71+ from google .cloud import datacatalog_v1
7272
73- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
73+ datacatalog = datacatalog_v1 .DataCatalogClient ()
7474
7575 sql_resource = 'bigquery.table.`{}`.`{}`.`{}`' .format (
7676 project_id , dataset_id , table_id )
@@ -80,9 +80,9 @@ def lookup_bigquery_table_sql_resource(project_id, dataset_id, table_id):
8080
8181def lookup_pubsub_topic (project_id , topic_id ):
8282 """Retrieves Data Catalog entry for the given Pub/Sub Topic."""
83- from google .cloud import datacatalog_v1beta1
83+ from google .cloud import datacatalog_v1
8484
85- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
85+ datacatalog = datacatalog_v1 .DataCatalogClient ()
8686
8787 resource_name = '//pubsub.googleapis.com/projects/{}/topics/{}' \
8888 .format (project_id , topic_id )
@@ -94,9 +94,9 @@ def lookup_pubsub_topic_sql_resource(project_id, topic_id):
9494 """Retrieves Data Catalog entry for the given Pub/Sub Topic by
9595 sql_resource.
9696 """
97- from google .cloud import datacatalog_v1beta1
97+ from google .cloud import datacatalog_v1
9898
99- datacatalog = datacatalog_v1beta1 .DataCatalogClient ()
99+ datacatalog = datacatalog_v1 .DataCatalogClient ()
100100
101101 sql_resource = 'pubsub.topic.`{}`.`{}`' .format (project_id , topic_id )
102102
0 commit comments