[WIP] clp-package: Pass search arguments via msgpack object instead of command line to search processes. #421
+465
−726
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description
This PR modifies clp-s and clo to pass most search arguments via a msgpack object written to stdin instead of via command line arguments. This allows the
fs_search_task
python wrapper to be less smart, and makes it easier to change the arguments passed to our search processes -- now we just need to modify theSearchConfig
object injob_config.py
and make clo/clp-s use the new fields directly.The diff is somewhat large, but mostly consists of simple changes to the
CommandLineArguments
classes of clp-s and clo to take config from a msgpack object instead of from command line arguments.We also change the search scheduler to make it augment the
SearchConfig
object with a mongodb output destination when no other output destination is specified. Having the mongodb output destination configured explicitly before the search job gets passed downstream allows downstream components to be less smart, and adding the mongodb output destination needs to happen inside the scheduler to follow our current convention that the job id is the result collection name.Validation performed