@@ -370,0 +406,4 @@
+                self.sheet.values()
+                .get(
+                    spreadsheetId=self.spreadsheet_id,
+                    range=f"{self.worksheet_name}!A{row_num}:Z{row_num}",

@@ -114,2 +118,4 @@
                     ["error", "error message"]
                 )
+                self.last_shard_col = self._find_column_index(
+                    ["last completed shard", "last shard", "shard"]

@@ -158,0 +183,4 @@
+
+            # Use dynamic range: A to max_column (or Z if no columns found)
+            if max_col >= 0:
+                end_col = self._col_letter(max_col + 1)  # +1 because _col_letter is 1-indexed

@@ -370,0 +447,4 @@
+                )
+                .execute()
+            )
+            values = result.get("values", [])

@@ -370,0 +433,4 @@
+
+            # Use dynamic range: A to max_column (or Z if no columns found)
+            if max_col >= 0:
+                end_col = self._col_letter(max_col + 1)  # +1 because _col_letter is 1-indexed

@@ -370,0 +532,4 @@
+                )
+
+            if self.last_updated_col is not None:
+                from datetime import datetime

@@ -150,2 +176,4 @@
     console = Console()
     console.print("[yellow]Streaming Turtle from line iterator[/yellow]")
+    if skip_triples > 0:
+        console.print(f"[dim]Resume mode: will skip {skip_triples:,} already-processed triples[/dim]")

@@ -152,0 +179,4 @@
+        console.print(f"[dim]Resume mode: will skip {skip_triples:,} already-processed triples[/dim]")
+
+    if num_workers is None:
+        num_workers = max(1, mp.cpu_count() - 1)

@@ -193,0 +232,4 @@
+                        console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")
+                    continue
+                elif total_triples == skip_triples:
+                    console.print(f"[green]✓ Skipped {skip_triples:,} triples, resuming normal parsing[/green]")

@@ -199,1 +262,3 @@
-            console.print(f"[dim]Processed {line_count:,} lines...[/dim]")
+            if line_count % PROGRESS_LOG_INTERVAL == 0:
+                if total_triples < skip_triples:
+                    console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")

@@ -159,0 +189,4 @@
+    # Extract prefix declarations first
+    buffered_first_line = None
+    for line in lines:
+        line_count += 1

@@ -190,0 +210,4 @@
+        if buffered_first_line:
+            yield buffered_first_line
+        for line in lines:
+            yield line

@@ -193,0 +229,4 @@
+
+                if total_triples < skip_triples:
+                    if total_triples % PROGRESS_LOG_INTERVAL == 0:
+                        console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")

@@ -193,0 +238,4 @@
+                triple_count += 1
+
+                if triple_count >= chunk_size:
+                    chunk_text = prefix_text + "\n" + "".join(current_chunk) + "\n" + line

@@ -221,1 +365,4 @@
     """
+    console = Console()
+    if skip_triples > 0:
+        console.print(f"[dim]Resume mode: will skip {skip_triples:,} already-processed triples[/dim]")

@@ -227,0 +379,4 @@
+
+        if total_triples < skip_triples:
+            if total_triples % PROGRESS_LOG_INTERVAL == 0:
+                console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")

@@ -227,0 +382,4 @@
+                console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")
+            continue
+        elif total_triples == skip_triples:
+            console.print(f"[green]✓ Skipped {skip_triples:,} triples, resuming normal parsing[/green]")

@@ -211,0 +274,4 @@
+                if triples:
+                    yield triples
+            except Exception as e:
+                logger.error(f"Error parsing final Turtle chunk: {e}")

@@ -211,0 +303,4 @@
+
+                if total_triples < skip_triples:
+                    if total_triples % PROGRESS_LOG_INTERVAL == 0:
+                        console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")

@@ -211,0 +306,4 @@
+                        console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")
+                    continue
+                elif total_triples == skip_triples:
+                    console.print(f"[green]✓ Skipped {skip_triples:,} triples, resuming normal parsing[/green]")

@@ -211,0 +309,4 @@
+                    console.print(f"[green]✓ Skipped {skip_triples:,} triples, resuming normal parsing[/green]")
+                    continue
+
+                sub_chunk_triple_count += 1

@@ -211,0 +319,4 @@
+                    sub_chunk_triple_count = 0
+
+                    if len(sub_chunks) >= batch_size:
+                        for idx, triples in pool.imap(_parse_turtle_chunk, sub_chunks):

@@ -319,0 +482,4 @@
+        return []
+
+
+def _parse_description_batch(args: tuple[int, str, str | None]) -> tuple[int, list[dict]]:

@@ -211,0 +331,4 @@
+
+            if line_count % PROGRESS_LOG_INTERVAL == 0:
+                if total_triples < skip_triples:
+                    console.print(f"[dim]Fast-forward: {total_triples:,} / {skip_triples:,} triples[/dim]")

@@ -211,0 +342,4 @@
+
+        # Process remaining batch
+        if sub_chunks:
+            for idx, triples in pool.imap(_parse_turtle_chunk, sub_chunks):

@@ -340,2 +523,4 @@
     console = Console()
     console.print("[yellow]Streaming RDF/XML with standard XML parser[/yellow]")
+    if skip_descriptions > 0:
+        console.print(f"[dim]Resuming: will skip {skip_descriptions:,} already-processed descriptions[/dim]")

@@ -359,0 +564,4 @@
+                    elem.clear()
+                    if total_descriptions % PROGRESS_LOG_INTERVAL == 0:
+                        console.print(
+                            f"[dim]Skipping: {total_descriptions:,} / {skip_descriptions:,}[/dim]"

@@ -376,2 +575,2 @@
-                    triple_batch = []
-                    batch_description_count = 0
+                if len(parse_batch) >= parse_batch_size:
+                    for idx, triples in pool.imap(_parse_description_batch, parse_batch):

@@ -388,1 +596,4 @@
         logger.error("This may indicate malformed XML in the source file")
+    finally:
+        if parse_batch:
+            for idx, triples in pool.imap(_parse_description_batch, parse_batch):

@@ -440,2 +661,3 @@
+        yield from stream_turtle_chunks_from_lines(lines, chunk_size, skip_triples, num_workers)
     elif format in ("xml", "rdf", "rdfxml"):
-        yield from stream_rdfxml_chunks_from_lines(lines, chunk_size=chunk_size)
+        yield from stream_rdfxml_chunks_from_lines(lines, chunk_size=chunk_size, skip_descriptions=skip_descriptions, num_workers=num_workers)

@@ -438,2 +659,3 @@
+        yield from stream_ntriples_from_lines(lines, skip_triples)
     elif format in ("turtle", "ttl"):
-        yield from stream_turtle_chunks_from_lines(lines, chunk_size=chunk_size)
+        yield from stream_turtle_chunks_from_lines(lines, chunk_size, skip_triples, num_workers)

@@ -638,3 +864,3 @@
 
         chunk_iter = stream_rdf_chunks_from_lines(
-            lines, format=rdf_format, chunk_size=DEFAULT_BATCH_SIZE
+            lines, rdf_format, DEFAULT_BATCH_SIZE, skip_descriptions, skip_triples, num_workers

@@ -1459,0 +1730,4 @@
+    if checkpoint_source:
+        console.print(f"[yellow]Resuming from shard {start_shard} (loaded from {checkpoint_source})[/yellow]")
+        if skip_descriptions > 0:
+            console.print(f"[yellow]Will skip {skip_descriptions:,} already-processed descriptions[/yellow]")

@@ -1459,0 +1728,4 @@
+            checkpoint_source = "sheet"
+
+    if checkpoint_source:
+        console.print(f"[yellow]Resuming from shard {start_shard} (loaded from {checkpoint_source})[/yellow]")