From 6bace7594edf79de8acd731d7bba2345756200b5 Mon Sep 17 00:00:00 2001 From: Aaron Z Date: Wed, 3 Apr 2024 20:14:36 -0400 Subject: [PATCH 1/3] updating python version --- setup.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/setup.py b/setup.py index 46cc6c3..1615cf8 100644 --- a/setup.py +++ b/setup.py @@ -19,7 +19,7 @@ setup( name="dbignite", version=VERSION, - python_requires='>=3.9.*', + python_requires='>=3.9', author="Amir Kermany, Nathan Buesgens, Rachel Sim, Aaron Zavora, William Smith, Jesse Young", author_email="labs@databricks.com", description= DESCRIPTION, From f64960500d7c55490b28405978ef3184e048edff Mon Sep 17 00:00:00 2001 From: Aaron Zavora Date: Thu, 2 May 2024 15:23:02 -0400 Subject: [PATCH 2/3] Update fhir_resource.py --- dbignite/fhir_resource.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbignite/fhir_resource.py b/dbignite/fhir_resource.py index 867c587..f2d04e1 100644 --- a/dbignite/fhir_resource.py +++ b/dbignite/fhir_resource.py @@ -192,7 +192,7 @@ def __filter_resources(column: Column, resource_type: str) -> Column: # def bulk_table_write(self, location = "", write_mode = "append", columns = None): pool = ThreadPool(mp.cpu_count()-1) - list(pool.map(lambda column: self.table_write(str(column), location, write_mode), ([c for c in self.entry().columns if c not in ["id", "timestamp"]] if columns is None else columns))) + list(pool.map(lambda column: self.table_write(str(column), location, write_mode), ([c for c in self.entry().columns if c not in ["id", "timestamp", "bundleuuid"]] if columns is None else columns))) # # Write an individual FHIR resource as a table From 29f8bc622ceee67ae333144b8486d0cb488070a9 Mon Sep 17 00:00:00 2001 From: Aaron Zavora Date: Thu, 2 May 2024 15:46:44 -0400 Subject: [PATCH 3/3] Update fhir_resource.py --- dbignite/fhir_resource.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbignite/fhir_resource.py b/dbignite/fhir_resource.py index f2d04e1..190fd80 100644 --- a/dbignite/fhir_resource.py +++ b/dbignite/fhir_resource.py @@ -192,7 +192,7 @@ def __filter_resources(column: Column, resource_type: str) -> Column: # def bulk_table_write(self, location = "", write_mode = "append", columns = None): pool = ThreadPool(mp.cpu_count()-1) - list(pool.map(lambda column: self.table_write(str(column), location, write_mode), ([c for c in self.entry().columns if c not in ["id", "timestamp", "bundleuuid"]] if columns is None else columns))) + list(pool.map(lambda column: self.table_write(str(column), location, write_mode), ([c for c in self.entry().columns if c not in ["id", "timestamp", "bundleUUID"]] if columns is None else columns))) # # Write an individual FHIR resource as a table