Add project name to dataset name

Author: murtazajafferji

admin/unmute_all_datasets.py

@@ -47,7 +47,7 @@ def getWarehouses(mcdId,mcdToken):
 def get_dataset_query(dwId,first: Optional[int] = 1000, after: Optional[str] = None) -> Query:
 	query = Query()
 	get_datasets = query.get_datasets(first=first, dw_id=dwId, **(dict(after=after) if after else {}))
-	get_datasets.edges.node.__fields__("dataset","uuid","is_muted")
+	get_datasets.edges.node.__fields__("dataset","project","uuid","is_muted")
 	get_datasets.page_info.__fields__(end_cursor=True)
 	get_datasets.page_info.__fields__("has_next_page")
 	return query
@@ -59,8 +59,8 @@ def getDatasetUuidDict(mcdId,mcdToken,dwId):
 	while True:
 		response = client(get_dataset_query(dwId=dwId,after=next_token)).get_datasets
 		for dataset in response.edges:
-			if dataset.node.is_muted:
-				dataset_uuid_dict[dataset.node.dataset.lower()] = dataset.node.uuid
+			if dataset.node.is_muted == False:
+				dataset_uuid_dict[dataset.node.uuid] = f"{dataset.node.project.lower()}:{dataset.node.dataset.lower()}"
 		if response.page_info.has_next_page:
 			next_token = response.page_info.end_cursor
 		else:
@@ -80,7 +80,7 @@ def userReview(uuid_dict, dw_id):
 	with open(fname, 'w') as csvfile:
 		writer = csv.writer(csvfile)
 		writer.writerow(header)
-		for dataset, uuid in uuid_dict.items():
+		for uuid, dataset in uuid_dict.items():
 			writer.writerow([dataset, uuid])
 	userReview = input(f'Datasets to unmute written to file {fname} for your review. OK to proceed? (y/n) ').lower()
 
@@ -115,7 +115,7 @@ def unmute_datasets(mcdId,dwId,mcdToken,uuidDict):
 
 	unmuted_dataset_counter = 0
 	incremental_datasets = 0
-	for uuid in uuidDict.values():
+	for uuid in uuidDict.keys():
 		temp_obj=dict(dsId=uuid, dwId=dwId)
 		print(temp_obj)
 		uuid_list.append(temp_obj)