Skip to content

Commit 35c442d

Browse files
[io] fix: implement a fix for creating dataset
1 parent 4496a45 commit 35c442d

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

libs/io/garf_io/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,4 @@
1313
# limitations under the License.
1414
"""Write GarfReport to anywhere."""
1515

16-
__version__ = '0.1.2'
16+
__version__ = '0.1.3'

libs/io/garf_io/writers/bigquery_writer.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -118,12 +118,11 @@ def create_or_get_dataset(self) -> bigquery.Dataset:
118118
try:
119119
bq_dataset = self.client.get_dataset(self.dataset_id)
120120
except google_cloud_exceptions.NotFound:
121-
dataset_id = f'{self.project}.{self.dataset_id}'
122-
bq_dataset = bigquery.Dataset(dataset_id)
121+
bq_dataset = bigquery.Dataset(self.dataset_id)
123122
bq_dataset.location = self.location
124123
with contextlib.suppress(google_cloud_exceptions.Conflict):
125124
bq_dataset = self.client.create_dataset(bq_dataset, timeout=30)
126-
logger.info('Created new dataset %s', dataset_id)
125+
logger.info('Created new dataset %s', self.dataset_id)
127126
return bq_dataset
128127

129128
@tracer.start_as_current_span('bq.write')

0 commit comments

Comments
 (0)