from smelog.factory import BoundLogger from juno_monitoring.clients import service def handler(logger: BoundLogger): """Lambda job. Args: logger: Logger instance. Returns: JSON serializable response """ previous_date = service.apollo.get_last_date() current_date = service.dsp.get_juno_date() logger.debug(f"previous {previous_date}, current {current_date}") if not previous_date or current_date > previous_date: service.user_data.post_event(previous_date, current_date) logger.debug(f"previous {previous_date}, current {current_date} event sent") service.apollo.set_last_date(current_date) else: logger.debug(f"previous {previous_date}, current {current_date} up-to-date") return { "previous_date": previous_date.isoformat() if previous_date else None, "current_date": current_date.isoformat() }