in 5-app-infra/3-artifact-publish/docker/cdmc/tag_engine_api/Resources.py [0:0]
def get_resources(self, included_uris, excluded_uris):
#print('enter get_resources()')
#print('included_uris: ' + included_uris)
# find out what kind of resource we have
included_uris_list = included_uris.split(',')
resource_type = included_uris_list[0].strip().split('/')[0]
#print("resource_type: " + resource_type)
if resource_type == self.bigquery_resource:
included_resources = self.find_bq_resources(included_uris)
#print("included_resources: " + str(included_resources))
if excluded_uris is None or excluded_uris == "" or excluded_uris.isspace():
return included_resources
else:
#print("excluded_uris: " + excluded_uris)
excluded_resources = self.find_bq_resources(excluded_uris)
#print("excluded_resources: " + str(excluded_resources))
elif resource_type == self.gcs_resource:
included_resources = self.find_gcs_resources(included_uris)
if excluded_uris is None or excluded_uris == "" or excluded_uris.isspace():
return included_resources
else:
#print("excluded_uris: " + excluded_uris)
excluded_resources = self.find_gcs_resources(excluded_uris)
#print("excluded_resources: " + str(excluded_resources))
else:
print('Error: expected to get a bigquery or gcs resource type, but found this: ' + resource_type)
return None
remaining_resources = included_resources.difference(excluded_resources)
return remaining_resources