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;
}