Rust Programming Language.
Schedule::from_str(cron_expression) .expect("Couldn't start the scheduler. Check the cron expression."); let worker = WorkerBuilder::new("worker") .layer(RetryLayer::new(RetryPolicy::retries(3))) .stream(CronStream::new(schedule).into_stream()) .data(cron_execution_service) .build_fn(perform_task);