from app.database import SessionLocal
from app.models.processing_job import ProcessingJob
from app.models.stream import Stream

db = SessionLocal()
stream = db.query(Stream).filter(Stream.title == 'Hi').first()

if stream:
    stream.status = 'processing'
    job = ProcessingJob(
        stream_id=stream.id,
        job_type='transcode',
        status='pending'
    )
    db.add(job)
    db.commit()
    print(f'Created job for stream {stream.id}')
else:
    print('Stream not found')

db.close()