Fix cannot pickle error (#7598)

GitOrigin-RevId: 811d7277db2729321f7135140142303668de912e

Author: szymondudycz

examples/pipelines/adaptive-rag/app.py

@@ -26,16 +26,12 @@ class App(BaseModel):
     port: int = 8000
 
     with_cache: bool = True
-    cache_backend: InstanceOf[pw.persistence.Backend] = (
-        pw.persistence.Backend.filesystem("./Cache")
-    )
     terminate_on_error: bool = False
 
     def run(self) -> None:
         server = QASummaryRestServer(self.host, self.port, self.question_answerer)
         server.run(
             with_cache=self.with_cache,
-            cache_backend=self.cache_backend,
             terminate_on_error=self.terminate_on_error,
         )
 

examples/pipelines/adaptive-rag/app.yaml

@@ -69,8 +69,6 @@ question_answerer: !pw.xpacks.llm.question_answering.AdaptiveRAGQuestionAnswerer
 
 # Cache configuration
 # with_cache: true
-# cache_backend: !pw.persistence.Backend.filesystem
-#  path: ".Cache"
 
 # Set `terminate_on_error` to true if you want the program to terminate whenever any error is encountered
 # terminate_on_error: false

examples/pipelines/demo-document-indexing/app.py

@@ -26,16 +26,12 @@ class App(BaseModel):
     port: int = 8000
 
     with_cache: bool = True
-    cache_backend: InstanceOf[pw.persistence.Backend] = (
-        pw.persistence.Backend.filesystem("./Cache")
-    )
     terminate_on_error: bool = False
 
     def run(self) -> None:
         server = DocumentStoreServer(self.host, self.port, self.document_store)
         server.run(
             with_cache=self.with_cache,
-            cache_backend=self.cache_backend,
             terminate_on_error=self.terminate_on_error,
         )
 

examples/pipelines/demo-document-indexing/app.yaml

@@ -56,8 +56,6 @@ document_store: !pw.xpacks.llm.document_store.DocumentStore
 
 # Cache configuration
 # with_cache: true
-# cache_backend: !pw.persistence.Backend.filesystem
-#  path: ".Cache"
 
 # Set `terminate_on_error` to true if you want the program to terminate whenever any error is encountered
 # terminate_on_error: false

examples/pipelines/demo-question-answering/.env

@@ -26,16 +26,12 @@ class App(BaseModel):
     port: int = 8000
 
     with_cache: bool = True
-    cache_backend: InstanceOf[pw.persistence.Backend] = (
-        pw.persistence.Backend.filesystem("./Cache")
-    )
     terminate_on_error: bool = False
 
     def run(self) -> None:
         server = QASummaryRestServer(self.host, self.port, self.question_answerer)
         server.run(
             with_cache=self.with_cache,
-            cache_backend=self.cache_backend,
             terminate_on_error=self.terminate_on_error,
         )
 

examples/pipelines/demo-question-answering/app.py

@@ -65,8 +65,6 @@ question_answerer: !pw.xpacks.llm.question_answering.BaseRAGQuestionAnswerer
 
 # Cache configuration
 # with_cache: true
-# cache_backend: !pw.persistence.Backend.filesystem
-#  path: ".Cache"
 
 # Set `terminate_on_error` to true if you want the program to terminate whenever any error is encountered
 # terminate_on_error: false

examples/pipelines/demo-question-answering/app.yaml

@@ -36,16 +36,12 @@ class App(BaseModel):
     port: int = 8000
 
     with_cache: bool = True
-    cache_backend: InstanceOf[pw.persistence.Backend] = (
-        pw.persistence.Backend.filesystem("./Cache")
-    )
     terminate_on_error: bool = False
 
     def run(self) -> None:
         server = QASummaryRestServer(self.host, self.port, self.question_answerer)
         server.run(
             with_cache=self.with_cache,
-            cache_backend=self.cache_backend,
             terminate_on_error=self.terminate_on_error,
         )
 

examples/pipelines/gpt_4o_multimodal_rag/app.py

@@ -77,8 +77,6 @@ question_answerer: !pw.xpacks.llm.question_answering.BaseRAGQuestionAnswerer
 
 # Cache configuration
 # with_cache: true
-# cache_backend: !pw.persistence.Backend.filesystem
-#  path: ".Cache"
 
 # Set `terminate_on_error` to true if you want the program to terminate whenever any error is encountered
 # terminate_on_error: false

examples/pipelines/gpt_4o_multimodal_rag/app.yaml

@@ -26,16 +26,12 @@ class App(BaseModel):
     port: int = 8000
 
     with_cache: bool = True
-    cache_backend: InstanceOf[pw.persistence.Backend] = (
-        pw.persistence.Backend.filesystem("./Cache")
-    )
     terminate_on_error: bool = False
 
     def run(self) -> None:
         server = QASummaryRestServer(self.host, self.port, self.question_answerer)
         server.run(
             with_cache=self.with_cache,
-            cache_backend=self.cache_backend,
             terminate_on_error=self.terminate_on_error,
         )