r2

api/app.py

@@ -19,18 +19,18 @@ else:
     # If you are using debugpy and set GEVENT_SUPPORT=True, you can debug with gevent.
     if (flask_debug := os.environ.get("FLASK_DEBUG", "0")) and flask_debug.lower() in {"false", "0", "no"}:
         from gevent import monkey
+        #
+        # # gevent
+        # monkey.patch_all()
+        #
+        # from grpc.experimental import gevent as grpc_gevent  # type: ignore
+        #
+        # # grpc gevent
+        # grpc_gevent.init_gevent()
 
-        # gevent
-        monkey.patch_all()
-
-        from grpc.experimental import gevent as grpc_gevent  # type: ignore
-
-        # grpc gevent
-        grpc_gevent.init_gevent()
-
-        import psycogreen.gevent  # type: ignore
-
-        psycogreen.gevent.patch_psycopg()
+        # import psycogreen.gevent  # type: ignore
+        #
+        # psycogreen.gevent.patch_psycopg()
 
     from app_factory import create_app
 

api/core/app/apps/pipeline/pipeline_generator.py

@@ -236,6 +236,7 @@ class PipelineGenerator(BaseAppGenerator):
             "documents": [PipelineDocument(
                 id=document.id,
                 position=document.position,
+                data_source_type=document.data_source_type,
                 data_source_info=json.loads(document.data_source_info) if document.data_source_info else None,
                 name=document.name,
                 indexing_status=document.indexing_status,