Skip to content

Commit 6929e3a

Browse files
committed
Update scheduler test cases
1 parent 32186f7 commit 6929e3a

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

tests/scheduler.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
use Psr\Log\LogLevel;
1111
use function EdgeTelemetrics\EventCorrelation\php_cmd;
12+
use function EdgeTelemetrics\EventCorrelation\wrap_source_php_cmd;
1213

1314
error_reporting( E_ALL );
1415
ini_set('display_errors', "on");
@@ -33,8 +34,9 @@ public function __construct(array $rules)
3334
set_exception_handler([$this, "handle_exception"]);
3435
$this->setLogger(new StderrLogger(LogLevel::DEBUG));
3536

36-
$this->register_input_process('test_data_stream_1', php_cmd(__DIR__ . "/Sources/test_input_1.php"));
37+
$this->register_input_process('test_data_stream_1', wrap_source_php_cmd(__DIR__ . "/Sources/test_input_1.php"));
3738
$this->register_input_process('test_data_stream_2', php_cmd(__DIR__ . "/Sources/test_input_2.php"));
39+
$this->register_input_process('test_misconfigured_input', php_cmd(__DIR__ . "/Sources/noexist.php"));
3840

3941
if (file_exists('/tmp/php_ec-scheduler_test_logs.txt')) {
4042
unlink('/tmp/php_ec-scheduler_test_logs.txt');
@@ -45,6 +47,7 @@ public function __construct(array $rules)
4547

4648
$this->setSavefileName("/tmp/php_ec-scheduler_test.state");
4749
$this->setSaveStateInterval(1);
50+
$this->enableManagementServer(true);
4851
}
4952

5053
function handle_exception($exception) {

0 commit comments

Comments
 (0)