diff --git a/transcribe.py b/transcribe.py
index 5d685e0..bfebca7 100644
--- a/transcribe.py
+++ b/transcribe.py
@@ -263,6 +263,11 @@ def main():
                             if draft_text:
                                 sys.stdout.write(f"\r\033[K[DRAFT]: {draft_text}")
                                 sys.stdout.flush()
+                                
+                                # Send draft to ingest if enabled
+                                if args.ingest:
+                                    ingest_queue.put({"draft": draft_text})
+                                    
                             last_stream_time = time.time()
                     
                     elif not speech_started and len(current_audio) > SAMPLERATE * 2: