RUNNER_TPL';
#![% shebang %]
use strict;
use warnings;
use Net::MQTT::Simple;
use DateTime;
use JSON;
use Capture::Tiny ':all';
my $dt_start = DateTime->now();
my $mqtt = Net::MQTT::Simple->new("[
:[% mqtt_port %]");
$mqtt->retain("[% base_topic %]/status/" . "[% task || "unknown" %]", encode_json({ status => "initiated", dt => "$dt_start", msg => "[% cmd %]" }) );
my $real_cmd = "[% job_dir %
$output =~ s/\n//g;
$mqtt->retain("[% base_topic %]/status/" . "[% task || "unknown" %]", encode_json({ status => "completed", dt => "$dt_end", last_line => "$last_line", output => "$output", elapsed