aggregation_modules/utils.py
def read_stream_metadata(self) -> dict:
        """
        reads stream.json file,
        containing stream specific details,
        from local disk and returns the dict
        """
        if "stream_file" in self.input_configs:
            return self.read_json_file_to_dict(
                os.path.join(self.config_dir,
                             self.input_configs["stream_file"])
            )
        return {}

        reads stream.json file,
        containing stream specific details,
        from local disk and returns the dict
        
reads stream.json file,
containing stream specific details,
from local disk and returns the dict
reads stream . json file containing stream specific details from local disk and returns the dict
def read_stream_metadata(self) -> dict:
        if "stream_file" in self.input_configs:
            return self.read_json_file_to_dict(
                os.path.join(self.config_dir,
                             self.input_configs["stream_file"])
            )
        return {}
def read_stream_metadata ( self ) -> dict : if "stream_file" in self . input_configs : return self . read_json_file_to_dict ( os . path . join ( self . config_dir , self . input_configs [ "stream_file" ] ) ) return { }
reads stream.json file,
containing stream specific details,
from local disk and returns the dict
reads stream . json file containing stream specific details from local disk and returns the dict
"""
        reads stream.json file,
        containing stream specific details,
        from local disk and returns the dict
        """
self