use log::info;
use serde_json::Value;
use elf_utils::*;
async fn my_task(_ctx: Context, payload: Value) -> Result<String, String> {
info!("Task running with sample value: {:?}",payload);
Ok("Task result".to_string())
}
#[tokio::main]
async fn main() {
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info"))
.format(json_format)
.init();
default_handle_script("my_task", my_task).await;
}