job max run time error message

Stepan Pesternikov · Stepan Pesternikov · commit a0093a7e7f0e · 2017-03-06T19:14:47.000+03:00
diff --git a/test/perl/t/jobMaxRunTime.t b/test/perl/t/jobMaxRunTime.t
@@ -22,7 +22,7 @@ $dbh->do($query);
 ok($dbh->err == 0) or (print $DBI::errstr . "\n" and $dbh->disconnect() and BAIL_OUT);
 
 $query = "SELECT schedule.create_job(\'{ \"name\": \"Test 1\",
-    \"cron\": \"* * * * *\",
+    \"cron\": \"*/3 * * * *\",
     \"commands\": [\"SELECT pg_sleep(120)\",
                     \"INSERT INTO test_results (time_mark, commentary) VALUES(now(), ''createJob'')\"],
     \"run_as\": \"tester\",
@@ -34,7 +34,7 @@ my $sth = $dbh->prepare($query);
 ok($sth->execute()) or (print $DBI::errstr . "\n" and $dbh->disconnect() and BAIL_OUT);
 my $job_id = $sth->fetchrow_array() and $sth->finish();
 
-sleep 130;
+sleep 250;
 $query = "SELECT count(*) FROM test_results";
 $sth = $dbh->prepare($query);
 ok($sth->execute()) or (print $DBI::errstr . "\n" and $dbh->disconnect() and BAIL_OUT);
@@ -48,6 +48,13 @@ $sth->bind_param(1, $job_id);
 ok($sth->execute(), $dbh->errstr) or print $DBI::errstr . "\n";
 $sth->finish();
 
+$query = "SELECT message FROM schedule.get_log() WHERE cron=$job_id AND status=\'error\' ORDER BY cron DESC LIMIT 1";
+my $sth = $dbh->prepare($query);
+ok($sth->execute()) or (print $DBI::errstr . "\n" and $dbh->disconnect() and BAIL_OUT);
+
+my $errorstr = $sth->fetchrow_array() and $sth->finish();
+ok($errorstr eq "job timeout") or print $DBI::errstr . "\n";
+
 $query = "DELETE FROM test_results;";
 $dbh->do($query);
 ok($dbh->err == 0, $dbh->errstr) or print $DBI::errstr . "\n";
