Version 1.1.18

Author: Ltamann

README.md

@@ -10,19 +10,19 @@ and at [patreon@TB_LAAR](https://www.patreon.com/TB_LAAR)).
 
 
 
-
-## V3 Migration Status
-
-This branch is migrated to ComfyUI v3 node loading and pins the API import to:
-
-```python
-from comfy_api.v0_0_2 import ComfyExtension, io, ui
-```
-
-Notes:
-- v3-only registration is provided via `comfy_entrypoint()`.
-- Legacy `NODE_CLASS_MAPPINGS` loading is no longer the primary path.
-- Input ids were normalized to snake_case in the v3 schema layer while keeping display labels.
+
+## V3 Migration Status
+
+This branch is migrated to ComfyUI v3 node loading and pins the API import to:
+
+```python
+from comfy_api.v0_0_2 import ComfyExtension, io, ui
+```
+
+Notes:
+- v3-only registration is provided via `comfy_entrypoint()`.
+- Legacy `NODE_CLASS_MAPPINGS` loading is no longer the primary path.
+- Input ids were normalized to snake_case in the v3 schema layer while keeping display labels.
 ## Table of Contents
 - [Overview](#overview)
 - [Early_Access](#Early_Access)
@@ -168,7 +168,7 @@ https://huggingface.co/black-forest-labs/FLUX.1-dev/resolve/main/vae/diffusion_p
 ## API_Access
 If you like to test the PRO feachers get early access by joining us at:
  - joining us at: https://www.patreon.com/TB_LAAR
- - get your API key from here:  https://api.tbgetur.com/login.php
+ - get your API key from here:  https://api.tbgetur.es/login.php
  - add environment variables using TBG_ETUR_API_KEY = your api key
     ![environment_var.png](img/environment_var.png)
 

TBG/CALLBACKS/constants.py

@@ -177,10 +177,12 @@ def __init__(self):
             Redux_Style_Model=None,
             Redux_Clip_Vision=None,
             Laplacian_Pyramid_Blending=None,
-            color_match_method=None,
-            color_match_str=None,
-            tiles_to_process_active=None,
-            tiles_to_process=None,
+            color_match_method=None,
+            color_match_str=None,
+            model_type=None,
+            Flux2_Tile_Color_Correction=True,
+            tiles_to_process_active=None,
+            tiles_to_process=None,
             Tile_Fusion_Mode=None,
             Refiner_Tile_Fusion_Mode=None,
             PRO_Fusion_Complexity_min_Denoise=0.2,
@@ -278,20 +280,21 @@ def __init__(self):
             shift = 0,
             shifttl =0,
             inpaint_blur_margin = 0,
-            composite_blur_margin = 0,
-            crop_margin=0,
-            tile_grid_W=1024,
-            tile_grid_H=1024,
-            rows_qty=1,
-            cols_qty=1,
-            outer_mask_area=0,
-            overlay_between_tiles=0,
-            fullW=1024,
-            fullH=1024,
-            UpscaledInputImageH=0,
-            UpscaledInputImageW=0,
-            Fusion_margin=64,
-        )
+            composite_blur_margin = 0,
+            crop_margin=0,
+            tile_grid_W=1024,
+            tile_grid_H=1024,
+            rows_qty=1,
+            cols_qty=1,
+            outer_mask_area=0,
+            overlay_between_tiles=0,
+            fullW=1024,
+            fullH=1024,
+            UpscaledInputImageH=0,
+            UpscaledInputImageW=0,
+            Fusion_reference_margin=0,
+            Fusion_margin=64,
+        )
 
         self.SEGMENTS = SimpleNamespace(
             segms=None,

TBG/SERVERS/COMFYUI_proxy.py

@@ -13,6 +13,7 @@
 import os
 import socket
 import struct
+import time
 from typing import Any
 
 import cloudpickle
@@ -58,6 +59,7 @@ def _compress_structure(obj):
 class MainController:
     # Class-level cache for the port to avoid repeated env lookups
     _port_cache: int | None = None
+    _connect_retry_delays = (0.25, 0.5, 1.0, 2.0, 4.0)
 
     @classmethod
     def _get_port(cls) -> int:
@@ -101,9 +103,7 @@ def call_main_method_old(
 
         data = cloudpickle.dumps(payload)
 
-        client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-        client.settimeout(None)
-        client.connect(("127.0.0.1", port))
+        client = cls._connect_with_retry(port, class_name, method_name)
         try:
             client.sendall(struct.pack("!Q", len(data)))
             client.sendall(data)
@@ -130,6 +130,38 @@ def call_main_method_old(
         finally:
             client.close()
 
+    @classmethod
+    def _connect_with_retry(cls, port: int, class_name: str, method_name: str) -> socket.socket:
+        rpc_name = f"{class_name}.{method_name}"
+        last_error = None
+
+        for attempt, delay in enumerate((0.0,) + cls._connect_retry_delays, start=1):
+            if delay > 0:
+                time.sleep(delay)
+
+            client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+            client.settimeout(None)
+            try:
+                client.connect(("127.0.0.1", int(port)))
+                if attempt > 1:
+                    print(f"[TBG_MAIN_RPC] Connected for {rpc_name} after retry {attempt - 1}")
+                return client
+            except OSError as e:
+                last_error = e
+                try:
+                    client.close()
+                except Exception:
+                    pass
+                if attempt <= len(cls._connect_retry_delays):
+                    print(
+                        f"[TBG_MAIN_RPC] Connect failed for {rpc_name} "
+                        f"(attempt {attempt}/{len(cls._connect_retry_delays) + 1}): {e}; retrying"
+                    )
+                    continue
+
+        print(f"[TBG_MAIN_RPC] Connect failed permanently for {rpc_name}: {last_error}")
+        raise last_error
+
     @classmethod
     def call_main_method(
         cls,

TBG/SERVERS/COMFYUI_server.py

@@ -51,7 +51,7 @@ def main_rpc_server(port: int) -> None:
     """
     server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server.bind(("127.0.0.1", int(port)))
-    server.listen(5)
+    server.listen(64)
     #print(f"🔌 MAIN RPC: Listening on port {port}")
 
     while True: