from celery import Celery
from celery.schedules import crontab
import datetime
import os


app = Celery('tasks', broker='redis://redis:6379/0')

# Define a task that runs every minute using a crontab schedule
@app.task
def ad_marker():
    os.system("echo '#EXT-X-CUE-OUT:30'  >> /app/data/hls/stream.m3u8")
    os.system("echo '#EXT-X-CUE-IN'  >> /app/data/hls/stream.m3u8")
    

# Define the crontab schedule
app.conf.beat_schedule = {
    'periodic-task': {
        'task': 'worker.tasks.ad_marker',
        'schedule': crontab(minute='*/1'),  # Run every minute
    },
}