19 using scarab::param_array;
20 using scarab::param_node;
21 using scarab::param_value;
32 param_node t_amqp_node = param_node();
33 t_amqp_node.add(
"broker",
"localhost" );
34 t_amqp_node.add(
"queue",
"psyllid" );
35 t_amqp_node.add(
"slack-queue",
"slack_interface" );
37 scarab::path t_auth_default_path = scarab::expand_path(
"~/.project8_authentications.json" );
38 if ( boost::filesystem::exists( t_auth_default_path ) )
40 LDEBUG(
plog,
"default auth file found, setting that as initial value" << t_auth_default_path.string() );
41 t_amqp_node.add(
"auth-file", t_auth_default_path.string() );
45 LDEBUG(
plog,
"default auth file <" << t_auth_default_path.string() <<
"> does not exist, not setting" );
54 add(
"amqp", t_amqp_node );
56 add(
"post-to-slack",
false );
58 param_node t_daq_node;
59 t_daq_node.add(
"activate-at-startup",
false );
60 t_daq_node.add(
"n-files", 1U );
61 t_daq_node.add(
"duration", 1000U );
62 t_daq_node.add(
"max-file-size-mb", 500.0 );
63 add(
"daq", t_daq_node );
65 param_node t_batch_commands;
66 param_array t_stop_array;
67 param_node t_stop_action;
68 t_stop_action.add(
"type",
"cmd" );
69 t_stop_action.add(
"rks",
"stop-run" );
70 t_stop_action.add(
"payload", param_node() );
71 t_stop_array.push_back( t_stop_action );
72 t_batch_commands.add(
"hard-abort", t_stop_array );
73 add(
"batch-commands", t_batch_commands );
75 param_node t_set_conditions;
76 t_set_conditions.add(
"10",
"hard-abort" );
77 t_set_conditions.add(
"12",
"hard-abort" );
78 add(
"set-conditions", t_set_conditions );
static scarab::logger plog("batch_executor")
LOGGER(plog, "egg_writer")