def process_writes(influxdb3_local, table_batches, args=None):
    site = args.get("site", "unknown") if args else "unknown"
    for table_batch in table_batches:
        message = (
            f"trigger smoke test: site={site} "
            f"table={table_batch['table_name']} rows={len(table_batch['rows'])}"
        )
        influxdb3_local.info(message)


def process_scheduled_call(influxdb3_local, call_time, args=None):
    site = args.get("site", "unknown") if args else "unknown"
    influxdb3_local.info(
        f"scheduled smoke test: site={site} call_time={call_time}"
    )