Parameterizing the condition

[abuchnick-aiola]

Hey everyone, would really appreciate your help here!

I have a server(implemented with FastAPI) that has an endpoint for setting up some settings, which one of them is the seconds and ms by which to setup the scheduler.
In order to support this capability, I want to use Rocketry and pass these parameters to the scheduler somehow, but I couldn't find any reference or documentation to it.
I tried to follow this guide but i probably miss something.
Below is the example for what I want to do:

server_app = FastAPI()
scheduler_app = Rocketry(execution="async")

# this is want I want to parameterize - the seconds and ms part
@scheduler_app.task(every("5 minute") & time_of_minute.at(start_second) & time_of_second.between(start_ms-100,start_ms+100))
async def do():
    print(f"Started at: {datetime.now()}")

class ScheduleRequest(pydantic.BaseModel):
   ..some params..
    start_second: int
    start_ms: int

@server_app.get("/setup_scheduler")
async def setup_scheduler(params: ScheduleRequest):
    # init params
   ..some params..
    start_second = params.start_second
    start_ms = params.start_ms
   ..some logic..

   # start scheduler by interval
   #what should be here? I want to schedule the do function to run every 5 minutes, at start_second seconds, and at milliseconds between [start_ms-100, start_ms+100]

if __name__ == "__main__":
   server_app.run()
   scheduler_app.run()

Thanks!

[abuchnick-aiola]

I found a way to do it, thanks :)