import Ġcom . fasterxml . jackson . databind . ObjectMapper Ċ import Ġjava . net . URI Ċ import Ġjava . net . http . HttpClient Ċ import Ġjava . net . http . HttpRequest Ċ import Ġjava . net . http . HttpResponse Ċ import Ġjava . util .* Ċ Ċ fun Ġtrigger Workflow ( dag : ĠString ) Ġ{ ĊĠĠĠ Ġval Ġvalues Ġ= Ġmap Of (" conf " Ġto Ġ{}) ĊĊĠĠĠ Ġval ĠobjectMapper Ġ= ĠObjectMapper () ĊĠĠĠ Ġval Ġrequest Body : ĠString Ġ= ĠobjectMapper ĊĠĠĠĠĠĠĠ Ġ. writeValue AsString ( values ) ĊĊĠĠĠ Ġval Ġauth Ġ= ĠBase 6 4 . get Encoder (). encode ((" airflow " Ġ+ Ġ":" Ġ+ Ġ" airflow ") ĊĠĠĠĠĠĠĠ Ġ. toByteArray ()). toString ( Charsets . UTF _ 8 ) ĊĠĠĠ Ġval Ġclient Ġ= ĠHttpClient . newBuilder (). build (); ĊĠĠĠ Ġval Ġrequest Ġ= ĠHttpRequest . newBuilder () ĊĠĠĠĠĠĠĠ Ġ. uri ( URI . create (" http :// localhost : 8 0 8 0 / api / v 1 / d ags /$ dag / dag Runs ")) ĊĠĠĠĠĠĠĠ Ġ. header (" Content - Type ", Ġ" application / json ") ĊĠĠĠĠĠĠĠ Ġ. header (" Authorization ", Ġ" Basic Ġ$ auth ") ĊĠĠĠĠĠĠĠ Ġ. POST ( HttpRequest . Body Publish ers . of String ( request Body )) ĊĠĠĠĠĠĠĠ Ġ. build () ĊĠĠĠ Ġval Ġresponse Ġ= Ġclient . send ( request , ĠHttpResponse . Body Handlers . of String ()); ĊĠĠĠ Ġprintln ( response . body ()) Ċ } Ċ