Skip to content

Instantly share code, notes, and snippets.

@pdmack

pdmack/gist:423e383a21d14352126c3cd993b21fb1 Secret

Created December 14, 2022 15:20
Show Gist options
  • Save pdmack/423e383a21d14352126c3cd993b21fb1 to your computer and use it in GitHub Desktop.
Save pdmack/423e383a21d14352126c3cd993b21fb1 to your computer and use it in GitHub Desktop.
Download ZIP
interrogate -vv -pPsiImM -r "name$" -r "supports_cpp_node$" --no-color --omit-covered-files morpheus
Raw
gistfile1.txt
=============================================================== Coverage for /root/github/Morpheus/morpheus/ ================================================================
----------------------------------------------------------------------------- Detailed Coverage -----------------------------------------------------------------------------
| Name | Status |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| config.py | |
| auto_determine_bootstrap (L28) | COVERED |
| ConfigBase (L55) | COVERED |
| ConfigOnnxToTRT (L61) | COVERED |
| AEFeatureScalar (L95) | COVERED |
| ConfigAutoEncoder (L103) | COVERED |
| ConfigFIL (L132) | MISSED |
| PipelineModes (L136) | COVERED |
| CppConfig (L144) | COVERED |
| CppConfig.get_should_use_cpp (L158) | COVERED |
| CppConfig.set_should_use_cpp (L165) | COVERED |
| Config (L173) | COVERED |
| Config.save (L228) | COVERED |
| Config.to_string (L241) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/commands.py | |
| add_command (L66) | MISSED |
| AliasedGroup (L72) | MISSED |
| AliasedGroup.get_command (L74) | MISSED |
| PluginGroup (L82) | MISSED |
| PluginGroup.list_commands (L98) | MISSED |
| PluginGroup.get_command (L120) | MISSED |
| cli (L160) | MISSED |
| tools (L187) | MISSED |
| onnx_to_trt (L199) | MISSED |
| autocomplete (L218) | MISSED |
| show (L227) | COVERED |
| install (L247) | COVERED |
| run (L283) | MISSED |
| pipeline_nlp (L315) | COVERED |
| pipeline_fil (L383) | COVERED |
| pipeline_ae (L470) | COVERED |
| pipeline_other (L553) | COVERED |
| post_pipeline (L601) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/default_command_hooks.py | |
| DefaultCommandHooks (L25) | MISSED |
| DefaultCommandHooks.morpheus_cli_collect_stage_names (L28) | MISSED |
| DefaultCommandHooks.morpheus_cli_make_stage_command (L36) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/hookspecs.py | |
| morpheus_cli_collect_stages (L28) | MISSED |
| morpheus_cli_collect_stage_names (L33) | MISSED |
| morpheus_cli_make_stage_command (L38) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/plugin_manager.py | |
| PluginManager (L31) | MISSED |
| PluginManager.add_plugin_option (L93) | MISSED |
| PluginManager.get_registered_stages (L97) | MISSED |
| PluginManager.get (L112) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/register_stage.py | |
| class_name_to_command_name (L42) | MISSED |
| get_param_doc (L50) | MISSED |
| get_param_type (L62) | MISSED |
| parse_type_value (L71) | MISSED |
| parse_doc_type_str (L103) | MISSED |
| get_doc_kwargs (L127) | MISSED |
| partial_pop_kwargs (L138) | COVERED |
| has_matching_kwargs (L155) | MISSED |
| set_options_param_type (L164) | MISSED |
| compute_option_name (L207) | MISSED |
| register_stage (L225) | MISSED |
| register_stage.register_stage_inner (L235) | MISSED |
| register_stage.register_stage_inner.build_command (L245) | MISSED |
| register_stage.register_stage_inner.build_command.command_callback (L309) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/run.py | |
| run_cli (L16) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/stage_registry.py | |
| StageInfo (L28) | MISSED |
| StageInfo.supports_mode (L39) | MISSED |
| LazyStageInfo (L50) | MISSED |
| StageRegistry (L89) | MISSED |
| StageRegistry.add_stage_info (L113) | MISSED |
| StageRegistry.get_stage_info (L119) | MISSED |
| StageRegistry.get_registered_names (L142) | MISSED |
| StageRegistry.remove_stage_info (L162) | MISSED |
| GlobalStageRegistry (L169) | MISSED |
| GlobalStageRegistry.get (L174) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| cli/utils.py | |
| str_to_file_type (L39) | MISSED |
| without_empty_args (L51) | COVERED |
| without_empty_args.new_func (L56) | MISSED |
| show_defaults (L63) | COVERED |
| show_defaults.new_func (L68) | MISSED |
| prepare_command (L86) | MISSED |
| prepare_command.inner_prepare_command (L88) | COVERED |
| prepare_command.inner_prepare_command.new_func (L93) | MISSED |
| get_config_from_ctx (L115) | MISSED |
| get_pipeline_from_ctx (L124) | MISSED |
| get_log_levels (L138) | COVERED |
| parse_log_level (L145) | COVERED |
| get_enum_map (L156) | MISSED |
| get_enum_inv_map (L165) | MISSED |
| get_enum_values (L174) | MISSED |
| parse_enum (L181) | MISSED |
| load_labels_file (L196) | MISSED |
| get_package_relative_file (L201) | MISSED |
| MorpheusRelativePath (L222) | COVERED |
| MorpheusRelativePath.convert (L234) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| messages/message_base.py | |
| MessageImpl (L22) | MISSED |
| MessageBase (L45) | MISSED |
| MessageData (L58) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| messages/multi_ae_message.py | |
| MultiAEMessage (L26) | MISSED |
| MultiAEMessage.get_slice (L33) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| messages/multi_message.py | |
| MultiMessage (L29) | COVERED |
| MultiMessage.get_meta (L89) | COVERED |
| MultiMessage.get_meta_list (L117) | COVERED |
| MultiMessage.set_meta (L134) | COVERED |
| MultiMessage.get_slice (L155) | COVERED |
| MultiMessage.copy_meta_ranges (L183) | MISSED |
| MultiMessage.copy_ranges (L191) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| messages/multi_response_message.py | |
| get_output (L28) | COVERED |
| set_output (L58) | COVERED |
| ResponseMemory (L78) | COVERED |
| ResponseMemory.get_output (L83) | MISSED |
| ResponseMemoryProbs (L88) | MISSED |
| ResponseMemoryAE (L96) | MISSED |
| MultiResponseMessage (L106) | COVERED |
| MultiResponseMessage.get_output (L147) | COVERED |
| MultiResponseMessage.copy_output_ranges (L165) | MISSED |
| MultiResponseMessage.copy_ranges (L173) | MISSED |
| MultiResponseProbsMessage (L186) | COVERED |
| MultiResponseAEMessage (L208) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| pipeline/linear_pipeline.py | |
| LinearPipeline (L26) | COVERED |
| LinearPipeline.increment_segment_id (L46) | MISSED |
| LinearPipeline.set_source (L51) | COVERED |
| LinearPipeline.add_stage (L81) | COVERED |
| LinearPipeline.add_segment_boundary (L105) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| pipeline/pipeline.py | |
| Pipeline (L41) | COVERED |
| Pipeline.add_node (L99) | MISSED |
| Pipeline.add_edge (L120) | MISSED |
| Pipeline.add_segment_edge (L144) | MISSED |
| Pipeline.build (L161) | COVERED |
| Pipeline.build.inner_build (L179) | MISSED |
| Pipeline.start (L229) | MISSED |
| Pipeline.stop (L238) | MISSED |
| Pipeline.join (L248) | MISSED |
| Pipeline.build_and_start (L273) | MISSED |
| Pipeline.async_start (L286) | MISSED |
| Pipeline.visualize (L307) | MISSED |
| Pipeline.visualize.has_ports (L336) | MISSED |
| Pipeline.run (L510) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| pipeline/receiver.py | |
| Receiver (L27) | COVERED |
| Receiver.get_input_pair (L83) | MISSED |
| Receiver.link (L123) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| pipeline/source_stage.py | |
| SourceStage (L28) | COVERED |
| SourceStage.join (L102) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| pipeline/stream_wrapper.py | |
| StreamWrapper (L69) | COVERED |
| StreamWrapper.get_all_inputs (L201) | COVERED |
| StreamWrapper.get_all_input_stages (L218) | COVERED |
| StreamWrapper.get_all_outputs (L229) | COVERED |
| StreamWrapper.get_all_output_stages (L245) | COVERED |
| StreamWrapper.can_build (L273) | COVERED |
| StreamWrapper.build (L307) | COVERED |
| StreamWrapper.start (L383) | MISSED |
| StreamWrapper.stop (L392) | COVERED |
| StreamWrapper.join (L398) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/general/monitor_stage.py | |
| MorpheusTqdmMonitor (L39) | MISSED |
| MorpheusTqdmMonitor.run (L41) | MISSED |
| MorpheusTqdm (L77) | COVERED |
| MorpheusTqdm.update (L114) | MISSED |
| MorpheusTqdm.stop (L120) | MISSED |
| MonitorStage (L127) | COVERED |
| MonitorStage.accepted_types (L182) | COVERED |
| MonitorStage.on_start (L197) | MISSED |
| MonitorStage.stop (L206) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/inference/inference_stage.py | |
| InferenceWorker (L34) | COVERED |
| InferenceWorker.init (L50) | MISSED |
| InferenceWorker.stop (L54) | MISSED |
| InferenceWorker.build_output_message (L57) | COVERED |
| InferenceWorker.calc_output_dims (L87) | COVERED |
| InferenceWorker.process (L104) | COVERED |
| InferenceStage (L121) | COVERED |
| InferenceStage.accepted_types (L170) | COVERED |
| InferenceStage.stop (L274) | MISSED |
| InferenceStage.join (L281) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/inference/triton_inference_stage.py | |
| TritonInOut (L69) | COVERED |
| ResourcePool (L100) | COVERED |
| ResourcePool.borrow (L144) | MISSED |
| ResourcePool.return_obj (L149) | MISSED |
| InputWrapper (L153) | COVERED |
| InputWrapper.get_bytes (L187) | COVERED |
| InputWrapper.get_offset (L204) | COVERED |
| InputWrapper.get_ptr (L221) | COVERED |
| InputWrapper.build_input (L271) | COVERED |
| ShmInputWrapper (L299) | COVERED |
| ShmInputWrapper.build_input (L343) | COVERED |
| TritonInferenceNLP (L602) | COVERED |
| TritonInferenceNLP.needs_logits (L648) | MISSED |
| TritonInferenceNLP.default_inout_mapping (L652) | MISSED |
| TritonInferenceFIL (L674) | COVERED |
| TritonInferenceFIL.default_inout_mapping (L720) | MISSED |
| TritonInferenceAE (L742) | COVERED |
| TritonInferenceStage (L834) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/input/autoencoder_source_stage.py | |
| AutoencoderSourceStage (L35) | COVERED |
| AutoencoderSourceStage.get_match_pattern (L114) | COVERED |
| AutoencoderSourceStage.repeat_df (L122) | MISSED |
| AutoencoderSourceStage.batch_user_split (L143) | MISSED |
| AutoencoderSourceStage.files_to_dfs_per_user (L191) | MISSED |
| AutoencoderSourceStage.derive_features (L200) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/input/azure_source_stage.py | |
| AzureSourceStage (L28) | COVERED |
| AzureSourceStage.change_columns (L73) | MISSED |
| AzureSourceStage.derive_features (L79) | MISSED |
| AzureSourceStage.files_to_dfs_per_user (L115) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/input/cloud_trail_source_stage.py | |
| CloudTrailSourceStage (L33) | COVERED |
| CloudTrailSourceStage.get_match_pattern (L51) | COVERED |
| CloudTrailSourceStage.read_file (L59) | COVERED |
| CloudTrailSourceStage.cleanup_df (L95) | MISSED |
| CloudTrailSourceStage.cleanup_df.remove_null (L102) | COVERED |
| CloudTrailSourceStage.cleanup_df.clean_column (L114) | COVERED |
| CloudTrailSourceStage.files_to_dfs_per_user (L141) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/input/duo_source_stage.py | |
| DuoSourceStage (L29) | COVERED |
| DuoSourceStage.change_columns (L73) | MISSED |
| DuoSourceStage.derive_features (L79) | MISSED |
| DuoSourceStage.files_to_dfs_per_user (L108) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/input/kafka_source_stage.py | |
| AutoOffsetReset (L37) | COVERED |
| KafkaSourceStage (L45) | COVERED |
| KafkaSourceStage.stop (L130) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/postprocess/generate_viz_frames_stage.py | |
| GenerateVizFramesStage (L45) | COVERED |
| GenerateVizFramesStage.accepted_types (L76) | COVERED |
| GenerateVizFramesStage.round_to_sec (L92) | COVERED |
| GenerateVizFramesStage.start_async (L167) | MISSED |
| GenerateVizFramesStage.start_async.client_connected (L174) | MISSED |
| GenerateVizFramesStage.start_async.run_server (L189) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| stages/postprocess/timeseries_stage.py | |
| round_seconds (L39) | MISSED |
| calc_bin (L43) | MISSED |
| zscore (L47) | COVERED |
| to_periodogram (L56) | COVERED |
| fftAD (L90) | COVERED |
| TimeSeriesAction (L139) | MISSED |
| UserTimeSeries (L149) | MISSED |
| TimeSeriesStage (L374) | COVERED |
| TimeSeriesStage.accepted_types (L435) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/atomic_integer.py | |
| AtomicInteger (L18) | COVERED |
| AtomicInteger.inc (L32) | MISSED |
| AtomicInteger.dec (L37) | COVERED |
| AtomicInteger.get_and_inc (L53) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/click_completion_tools.py | |
| get_code (L21) | MISSED |
| install_code (L46) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/compare_df.py | |
| filter_df (L26) | MISSED |
| compare_df (L64) | COVERED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/directory_watcher.py | |
| DirectoryWatcher (L35) | COVERED |
| DirectoryWatcher.build_node (L93) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/logger.py | |
| TqdmLoggingHandler (L28) | MISSED |
| TqdmLoggingHandler.emit (L36) | MISSED |
| configure_logging (L148) | COVERED |
| set_log_level (L177) | COVERED |
| deprecated_stage_warning (L206) | MISSED |
| get_log_levels (L213) | MISSED |
| parse_log_level (L222) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/producer_consumer_queue.py | |
| Closed (L25) | COVERED |
| ProducerConsumerQueue (L30) | COVERED |
| ProducerConsumerQueue.join (L52) | COVERED |
| ProducerConsumerQueue.put (L60) | MISSED |
| ProducerConsumerQueue.get (L86) | MISSED |
| ProducerConsumerQueue.close (L111) | MISSED |
| ProducerConsumerQueue.is_closed (L119) | MISSED |
| AsyncIOProducerConsumerQueue (L124) | COVERED |
| AsyncIOProducerConsumerQueue.join (L135) | COVERED |
| AsyncIOProducerConsumerQueue.put (L150) | COVERED |
| AsyncIOProducerConsumerQueue.get (L181) | COVERED |
| AsyncIOProducerConsumerQueue.close (L211) | MISSED |
| AsyncIOProducerConsumerQueue.is_closed (L222) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
| utils/type_utils.py | |
| greatest_ancestor (L32) | MISSED |
| unpack_union (L47) | MISSED |
| unpack_union (L52) | MISSED |
| unpack_union (L57) | MISSED |
| unpack_union (L62) | MISSED |
| unpack_tuple (L81) | MISSED |
| unpack_tuple (L86) | MISSED |
| unpack_tuple (L91) | MISSED |
| unpack_tuple (L96) | MISSED |
| pretty_print_type_name (L114) | COVERED |
| mirror_args (L125) | MISSED |
| get_full_qualname (L131) | MISSED |
|--------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|
---------------------------------------------------------------------------------- Summary ----------------------------------------------------------------------------------
| Name | Total | Miss | Cover | Cover% |
|-------------------------------------------------------------------|-------------------------|------------------------|-------------------------|--------------------------|
| config.py | 13 | 1 | 12 | 92% |
| cli/commands.py | 18 | 12 | 6 | 33% |
| cli/default_command_hooks.py | 3 | 3 | 0 | 0% |
| cli/hookspecs.py | 3 | 3 | 0 | 0% |
| cli/plugin_manager.py | 4 | 4 | 0 | 0% |
| cli/register_stage.py | 14 | 13 | 1 | 7% |
| cli/run.py | 1 | 1 | 0 | 0% |
| cli/stage_registry.py | 10 | 10 | 0 | 0% |
| cli/utils.py | 20 | 14 | 6 | 30% |
| messages/message_base.py | 3 | 3 | 0 | 0% |
| messages/multi_ae_message.py | 2 | 1 | 1 | 50% |
| messages/multi_message.py | 7 | 2 | 5 | 71% |
| messages/multi_response_message.py | 12 | 5 | 7 | 58% |
| pipeline/linear_pipeline.py | 5 | 1 | 4 | 80% |
| pipeline/pipeline.py | 14 | 11 | 3 | 21% |
| pipeline/receiver.py | 3 | 1 | 2 | 67% |
| pipeline/source_stage.py | 2 | 1 | 1 | 50% |
| pipeline/stream_wrapper.py | 10 | 2 | 8 | 80% |
| stages/general/monitor_stage.py | 9 | 6 | 3 | 33% |
| stages/inference/inference_stage.py | 10 | 4 | 6 | 60% |
| stages/inference/triton_inference_stage.py | 18 | 5 | 13 | 72% |
| stages/input/autoencoder_source_stage.py | 6 | 4 | 2 | 33% |
| stages/input/azure_source_stage.py | 4 | 3 | 1 | 25% |
| stages/input/cloud_trail_source_stage.py | 7 | 2 | 5 | 71% |
| stages/input/duo_source_stage.py | 4 | 3 | 1 | 25% |
| stages/input/kafka_source_stage.py | 3 | 1 | 2 | 67% |
| stages/postprocess/generate_viz_frames_stage.py | 6 | 3 | 3 | 50% |
| stages/postprocess/timeseries_stage.py | 9 | 4 | 5 | 56% |
| utils/atomic_integer.py | 4 | 1 | 3 | 75% |
| utils/click_completion_tools.py | 2 | 2 | 0 | 0% |
| utils/compare_df.py | 2 | 1 | 1 | 50% |
| utils/directory_watcher.py | 2 | 1 | 1 | 50% |
| utils/logger.py | 7 | 5 | 2 | 29% |
| utils/producer_consumer_queue.py | 13 | 6 | 7 | 54% |
| utils/type_utils.py | 12 | 11 | 1 | 8% |
|-------------------------------------------------------------------|-------------------------|------------------------|-------------------------|--------------------------|
| TOTAL | 379 | 150 | 229 | 60.4% |
|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| (41 of 76 files omitted due to complete coverage) |
-------------------------------------------------------------- RESULT: FAILED (minimum: 80.0%, actual: 60.4%) ---------------------------------------------------------------
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment