@@ -377,0 +389,4 @@
+
+    try:
+        with mp.Pool(processes=num_workers) as pool:
+            for triples in pool.imap_unordered(process_geonames_lines, batches, chunksize=1):

@@ -377,0 +424,4 @@
+
+    Module-level function for use in picklable generators.
+    """
+    is_gzipped = file_path.suffix == ".gz"

@@ -377,0 +425,4 @@
+    Module-level function for use in picklable generators.
+    """
+    is_gzipped = file_path.suffix == ".gz"
+    is_bz2 = file_path.suffix == ".bz2" or str(file_path).endswith(".ttl.bz2")

@@ -377,0 +465,4 @@
+
+                        triples = []
+                        for s, p, o in graph:
+                            if isinstance(o, Literal):

@@ -377,0 +510,4 @@
+
+                triples = []
+                for s, p, o in graph:
+                    if isinstance(o, Literal):

@@ -377,0 +553,4 @@
+
+    current_chunk = []
+    for s, p, o in graph:
+        if isinstance(o, Literal):

@@ -1022,3 +1148,3 @@
                         rate = triple_count / elapsed if elapsed > 0 else 0
                         progress_pct = 10 + min(60, int((chunk_count / estimated_chunks) * 60))
-                        self.progress.print(
+                        print(

@@ -1027,2 +1153,3 @@
+                            flush=True,
                         )
-                        self.progress.emit_progress(progress_pct)
+                        print(f"PROGRESS: {progress_pct}", flush=True)

@@ -1205,1 +1206,4 @@
 
+    # Fix for "AF_UNIX path too long" error in multiprocessing
+    # This forces the temporary directory to be /tmp (short path) instead of a potentially deep workspace path
+    os.environ["TMPDIR"] = "/tmp"