Just an extra question: We use the BackgroundScheduler, the way it locks job, I assume it is fully in memory? There is no lockfile or anything created that might be a 'residu' when the whole service running the scheduler restarts? (its a docker based service, if a jobs crash on unexpected exception, the service crashes and gets restarted automatically)
@cecemel
maybe use a library like tenacity to do progressive back-off
add a listener to the scheduler
Basically I want to do something similar to what this endpoint does but to get me the jobs that failed and if they will run again. How can I achieve that in the simplest way?
@app.get("/schedule/show_schedules/",response_model=CurrentScheduledJobsResponse,tags=["schedule"])
async def get_scheduled_syncs():
"""
Will provide a list of currently Scheduled Tasks
"""
schedules = []
for job in Schedule.get_jobs():
schedules.append({"job_id": str(job.id), "run_frequency": str(job.trigger), "next_run": str(job.next_run_time)})
return {"jobs":schedules}
if a the target function of a job causes an exception, it will still be run on its next calculated run time
what is the correct expression if want to trigger the job every hour between 0400 and 0600 (i.e. fires at time 0400, 0500 and 0600)
like it says, any value between 4-6. Those values are 4,5,6.
an attribute? to what?
have you read the API documentation for
add_job()?
did you expect there to be examples for every possible parameter of that method?
so İ have a Bot class which is from twitchio package, and that's running asynchronously.
what would I have to do if I wanted to make apshceduler and twitchio bot run together?
aim: I will update the data periodically so my bot will respond faster
from twitchio.ext import commands
class Bot(commands.Bot):
def __init__(self):
...
bot = Bot()
bot.run() # there is run_until_complete function in run()
ok, the source looks like it uses asyncio
I tried this but I get this error:
maxiumum number of running instances reached(1) but I set max_instances to 5try:
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(("127.0.0.1", 47200))
log.info("socket bind")
except socket.error:
log.info("socket error")
pass
else:
log.info("socket - register extensions")
scheduler = AsyncIOScheduler()
log.basicConfig()
log.getLogger("apscheduler").setLevel(log.DEBUG)
scheduler.start()
scheduler.add_job(
test_function,
trigger="interval",
id="test_job",
replace_existing=True,
seconds=30,
)
bot = Bot()
bot.run()
@agronholm
give me something that lets me see the problem
