Skip to content
Snippets Groups Projects
Verified Commit c4dd784e authored by ANA MANZANO RODRIGUEZ's avatar ANA MANZANO RODRIGUEZ Committed by Alberto Miranda
Browse files

ADM_update_job.cpp updated with job creation

parent caf0c5e1
No related branches found
No related tags found
1 merge request!12Resolve "Execute RPCs tests in CI"
...@@ -56,12 +56,28 @@ main(int argc, char* argv[]) { ...@@ -56,12 +56,28 @@ main(int argc, char* argv[]) {
admire::adhoc_storage::execution_mode::separate_new, admire::adhoc_storage::execution_mode::separate_new,
admire::adhoc_storage::access_type::read_write, 42, 100, false); admire::adhoc_storage::access_type::read_write, 42, 100, false);
admire::job job{42};
admire::job_requirements reqs{inputs, outputs, std::move(p)}; admire::job_requirements reqs{inputs, outputs, std::move(p)};
const auto job = admire::register_job(server, reqs);
std::vector<admire::dataset> new_inputs;
new_inputs.reserve(NINPUTS);
for(int i = 0; i < NINPUTS; ++i) {
new_inputs.emplace_back(fmt::format("input-new-dataset-{}", i));
}
std::vector<admire::dataset> new_outputs;
new_outputs.reserve(NOUTPUTS);
for(int i = 0; i < NOUTPUTS; ++i) {
new_outputs.emplace_back(fmt::format("output-new-dataset-{}", i));
}
admire::job_requirements new_reqs{new_inputs, new_outputs, std::move(p)};
ADM_return_t ret = ADM_SUCCESS; ADM_return_t ret = ADM_SUCCESS;
try { try {
ret = admire::update_job(server, job, reqs); ret = admire::update_job(server, job, new_reqs);
} catch(const std::exception& e) { } catch(const std::exception& e) {
fmt::print(stderr, "FATAL: ADM_update_job() failed: {}\n", e.what()); fmt::print(stderr, "FATAL: ADM_update_job() failed: {}\n", e.what());
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment