Skip to content

Commit 18eec29

Browse files
rarepolzRares Polenciuc
andauthored
fix: add sqlite in webrunner (#141)
Co-authored-by: Rares Polenciuc <rarepolz@amazon.com>
1 parent 6ce89d6 commit 18eec29

File tree

1 file changed

+5
-1
lines changed
  • src/aws_durable_execution_sdk_python_testing

1 file changed

+5
-1
lines changed

src/aws_durable_execution_sdk_python_testing/runner.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@
6565
from aws_durable_execution_sdk_python_testing.stores.memory import (
6666
InMemoryExecutionStore,
6767
)
68+
from aws_durable_execution_sdk_python_testing.stores.sqlite import SQLiteExecutionStore
6869
from aws_durable_execution_sdk_python_testing.web.server import WebServer
6970

7071

@@ -759,7 +760,10 @@ def start(self) -> None:
759760
raise DurableFunctionsLocalRunnerError(msg)
760761

761762
# Create dependencies and server
762-
if self._config.store_type == StoreType.FILESYSTEM:
763+
if self._config.store_type == StoreType.SQLITE:
764+
store_path = self._config.store_path
765+
self._store = SQLiteExecutionStore.create_and_initialize(store_path)
766+
elif self._config.store_type == StoreType.FILESYSTEM:
763767
store_path = self._config.store_path or ".durable_executions"
764768
self._store = FileSystemExecutionStore.create(store_path)
765769
else:

0 commit comments

Comments
 (0)