docs-v2/test/influxdb3-plugins/schedule.py

12 lines
474 B
Python

def process_scheduled_call(influxdb3_local, call_time, args=None):
"""
Process a scheduled call from the InfluxDB 3 processing engine.
Args:
influxdb3_local: Local InfluxDB API client
call_time: Time when the trigger was called
args: Optional arguments passed from the trigger configuration
"""
influxdb3_local.info(f"Processing scheduled call at {call_time}")
if args:
influxdb3_local.info(f"With arguments: {args}")