fix: Correct Peewee-AIO method calls in observe/distill

- Replace aio_get() with async for iteration
- Replace aio_create() with create()
- Replace aio_save() with save()

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: Spacehunterz

src/observe/elf_distill.py

@@ -120,7 +120,7 @@ async def apply_decay(project_path: Optional[str] = None) -> int:
                 if abs(new_strength - pattern.strength) > 0.001:
                     pattern.strength = new_strength
                     pattern.updated_at = now
-                    await pattern.aio_save()
+                    await pattern.save()
                     updated += 1
 
     return updated
@@ -267,7 +267,7 @@ async def promote_pattern_to_heuristic(pattern) -> int:
     async with m:
         async with m.connection():
             # Create heuristic
-            heuristic = await Heuristic.aio_create(
+            heuristic = await Heuristic.create(
                 domain=pattern.domain,
                 rule=pattern.pattern_text,
                 explanation=f"Auto-extracted pattern: {pattern.signature or 'behavioral'}. "
@@ -286,7 +286,7 @@ async def promote_pattern_to_heuristic(pattern) -> int:
             # Mark pattern as promoted
             pattern.promoted_to_heuristic_id = heuristic.id
             pattern.updated_at = datetime.utcnow()
-            await pattern.aio_save()
+            await pattern.save()
 
             return heuristic.id
 

src/observe/elf_observe.py

@@ -423,9 +423,12 @@ async def upsert_pattern(pattern: Dict[str, Any]) -> int:
     async with m:
         async with m.connection():
             # Try to find existing pattern
-            try:
-                existing = await Pattern.aio_get(Pattern.pattern_hash == pattern_hash)
+            existing = None
+            async for p in Pattern.select().where(Pattern.pattern_hash == pattern_hash):
+                existing = p
+                break
 
+            if existing:
                 # Update existing pattern
                 existing.occurrence_count += pattern.get('occurrence_count', 1)
                 existing.last_seen = now
@@ -438,12 +441,12 @@ async def upsert_pattern(pattern: Dict[str, Any]) -> int:
                 existing.session_ids = json.dumps(session_ids)
 
                 existing.updated_at = now
-                await existing.aio_save()
+                await existing.save()
                 return existing.id
 
-            except Pattern.DoesNotExist:
+            else:
                 # Create new pattern
-                new_pattern = await Pattern.aio_create(
+                new_pattern = await Pattern.create(
                     pattern_type=pattern['pattern_type'],
                     pattern_hash=pattern_hash,
                     pattern_text=pattern['pattern_text'],