klas/t6_mem0
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Set check_same_thread false so that one App can be used in parallel (#911)

Browse Source
This commit is contained in:
Sidharth Mohanty
2023-11-08 23:56:31 +05:30
committed by GitHub
parent 2b8b6d3ea9
commit d8cdbe0041
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
embedchain/embedchain.py
View File

@@ -88,7 +88,7 @@ class EmbedChain(JSONSerializable):
self._telemetry_props = {"class": self.__class__.__name__} self._telemetry_props = {"class": self.__class__.__name__}
self.telemetry = AnonymousTelemetry(enabled=self.config.collect_metrics) self.telemetry = AnonymousTelemetry(enabled=self.config.collect_metrics)
# Establish a connection to the SQLite database # Establish a connection to the SQLite database
self.connection = sqlite3.connect(SQLITE_PATH) self.connection = sqlite3.connect(SQLITE_PATH, check_same_thread=False)
self.cursor = self.connection.cursor() self.cursor = self.connection.cursor()
# Create the 'data_sources' table if it doesn't exist # Create the 'data_sources' table if it doesn't exist

2
embedchain/pipeline.py
View File

@@ -120,7 +120,7 @@ class Pipeline(EmbedChain):
self.telemetry = AnonymousTelemetry(enabled=self.config.collect_metrics) self.telemetry = AnonymousTelemetry(enabled=self.config.collect_metrics)
# Establish a connection to the SQLite database # Establish a connection to the SQLite database
self.connection = sqlite3.connect(SQLITE_PATH) self.connection = sqlite3.connect(SQLITE_PATH, check_same_thread=False)
self.cursor = self.connection.cursor() self.cursor = self.connection.cursor()
# Create the 'data_sources' table if it doesn't exist # Create the 'data_sources' table if it doesn't exist