in generate/resources/_bigquery.py [0:0]
def create_bq_dataset(self, dataset):
"create dataset"
dataset_name = dataset["dataset_id"]
dataset["project"] = self.tf_ref("project", dataset["project"])
for access in dataset.get("access", []):
if access.get("dataset_id"):
access["dataset_id"] = self.tf_ref("bq_dataset", access["dataset_id"])
if access.get("project_id"):
access["project_id"] = self.tf_ref("bq_project", access["project_id"])
if access.get("routine_id"):
access["routine_id"] = self.tf_ref("bq_routine", access["routine_id"])
self.tf_param_list(dataset, "access", BigqueryDatasetAccess)
self.created["bq_dataset"][dataset_name] = BigqueryDataset(
self, f"bqd_{dataset_name}", **dataset
)