notification_sender.bal

isolated class NotificationSender {
    *task:Job;
    private final string location;

    isolated function init(string location) {
        self.location = location;
    }

    public isolated function execute() {
        WeatherReport|error weatherReport = getWeatherReport(self.location);
        if weatherReport is error {
            log:printWarn(string `Error occurred while retrieving weather-report: ${weatherReport.message()}`, stackTrace = weatherReport.stackTrace());
            return;
        }
        error? persistResult = publishWeatherNotification(self.location, weatherReport);
        if persistResult is error {
            log:printWarn(string `Error occurred while persisting the weather-report: ${persistResult.message()}`, stackTrace = persistResult.stackTrace());
        }
    }
}

isolated function startNotificationSender(string location) returns task:JobId|error {
    NotificationSender notificationSender = new (location);
    // schedule the job to be run every 600 seconds (10 minutes)
    return task:scheduleJobRecurByFrequency(notificationSender, 600.0);
}