🚧 refactored: add method on services file that will implement.

app/core/services.py

@@ -132,6 +132,8 @@ def backup(self): ...
 
     def retention(self): ...
 
+    def init(self): ...
+
 
 class NodeIngest(BaseNode):
     """Node for Ingestion"""
@@ -148,6 +150,18 @@ def push(self):
 class Pipeline(PipelineCatalog):
     """Pipeline Service Model"""
 
+    def nodes(self): ...
+
+    def log_push(self): ...
+
+    def log_fetch(self): ...
+
+    def check_triggered(self): ...
+
+    def check_scheduled(self): ...
+
+    def schedule_push(self): ...
+
 
 class Task(BaseTask):
     """Task Service Model"""

app/core/statements.py

@@ -159,7 +159,9 @@ def statement_check(self) -> str:
         )
 
     def statement_create(
-        self, bk: bool = False, bk_name: Optional[str] = None
+        self,
+        bk: bool = False,
+        bk_name: Optional[str] = None,
     ) -> str:
         """Generate create statement
 
@@ -182,17 +184,21 @@ def statement_create(
         )
         return (
             re.sub(
-                r"{database_name}\.{ai_schema_name}\.\w+",
-                f"{{database_name}}.{{ai_schema_name_backup}}."
-                f"{bk_name or f'{self.name}_bk'}",
+                r"{{database_name}\.{ai_schema_name}\.\w+",
+                (
+                    f"{{database_name}}.{{ai_schema_name_backup}}."
+                    f"{bk_name or f'{self.name}_bk'}"
+                ),
                 create_stm,
             )
             if bk
             else create_stm
         )
 
     def statement_create_partition(
-        self, start: str, end: Optional[str] = None
+        self,
+        start: str,
+        end: Optional[str] = None,
     ) -> str:
         """Generate create partition statement