We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent aa13e93 commit 575d5ccCopy full SHA for 575d5cc
digital_land/commands.py
@@ -422,6 +422,11 @@ def dataset_create(
422
if pqpackage.strategy != "direct":
423
pqpackage.group_parquet_files(input_dir, target_mb=256)
424
pqpackage.load_facts(input_dir)
425
+ # temporary diagnostic to verify fact count before sqlite load
426
+ fact_parquet_count = pqpackage.conn.execute(
427
+ f"SELECT COUNT(*) FROM parquet_scan('{pqpackage.fact_path}')"
428
+ ).fetchone()[0]
429
+ logger.info(f"fact.parquet row count before sqlite load: {fact_parquet_count}")
430
pqpackage.load_fact_resource(input_dir)
431
pqpackage.load_entities(input_dir, resource_path, organisation_path)
432
0 commit comments