diff --git a/datastore/load-test/schedule_write.py b/datastore/load-test/schedule_write.py index d56969c8..88716190 100644 --- a/datastore/load-test/schedule_write.py +++ b/datastore/load-test/schedule_write.py @@ -93,7 +93,7 @@ def write_data(station): print(station_id, cron, period) # TODO: Spread less well over time, for example, all use same second, but add jitter < 60 trigger = CronTrigger(minute=cron, second=random.randint(0, 59), jitter=1) - scheduler.add_job(write_data, args=(station,), id=station_id, trigger=trigger) + scheduler.add_job(write_data, args=(station,), id=station_id, name=station_id, trigger=trigger) print("Press Ctrl+{0} to exit".format("Break" if os.name == "nt" else "C")) try: