pub async fn start_influxdb_worker( url: String, database: String, tags: HashMap<String, String>, event_receiver: Broadcaster<WriteQuery>, ) -> WorkerResult