Skip to content

Commit d91967e

Browse files
Fix record_count in partitioned case
1 parent e9a6d6b commit d91967e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Diff for: python-lib/dku_io_utils.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ def count_records(dataset: dataiku.Dataset) -> int:
3232
logging.info("Dataset {} contains {:d} records and is not partitioned".format(dataset.name, record_count))
3333
else:
3434
for partition in partitions:
35-
project.get_dataset(dataset.name).compute_metrics(partition=partition, metric_ids=[metric_id])
35+
project.get_dataset(dataset.short_name).compute_metrics(partition=partition, metric_ids=[metric_id])
3636
metric = dataset.get_last_metric_values()
3737
record_count += dataiku.ComputedMetrics.get_value_from_data(
3838
metric.get_partition_data(partition=partition, metric_id=metric_id)

0 commit comments

Comments
 (0)