Skip to content

Commit

Permalink
[low-code] Apply log level to stream loggers (airbytehq#17284)
Browse files Browse the repository at this point in the history
* Apply log level to stream loggers

* remove debug print
  • Loading branch information
girarda authored and jhammarstedt committed Oct 31, 2022
1 parent 9b02b64 commit 72c8ee4
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,11 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
"parsed YAML into declarative source",
extra={"path_to_yaml_file": self._path_to_yaml, "source_name": self.name, "parsed_config": json.dumps(self._source_config)},
)
return [self._factory.create_component(stream_config, config, True)() for stream_config in self._stream_configs()]
source_streams = [self._factory.create_component(stream_config, config, True)() for stream_config in self._stream_configs()]
for stream in source_streams:
# make sure the log level is always appied to the stream's logger
self._apply_log_level_to_stream_logger(self.logger, stream)
return source_streams

def _read_and_parse_yaml_file(self, path_to_yaml_file):
package = self.__class__.__module__.split(".")[0]
Expand Down

0 comments on commit 72c8ee4

Please sign in to comment.