feat(ingest): enable EnsureAspectSizeProcessor for all sources

[hsheth2]

Checklist

• The PR conforms to DataHub's Contributing Guideline (particularly Commit Message Format)
• Links to related issues (if applicable)
• Tests for the changes have been added/updated (if applicable)
• Docs related to the changes have been added/updated (if applicable). If a new feature has been added a Usage Guide has been added for the same.
• For any breaking change/potential downtime/deprecation/big changes an entry has been made in Updating DataHub

[skrydal]

We could remove such repeated conditionals, how about simply adding new function to the logging, i.e. in logging_manager.py:

def trace(self: logging.Logger, message: str, *args: Any, **kwargs: Any):
    env = f'TRACE_{self.name.replace(".", "__").upper()}'
    if get_boolean_env_variable(env, False):
        self._log(logging.DEBUG, message, args, **kwargs)


logging.Logger.trace = trace

Then here we would be only calling logger.trace(...). the variable to be exported in this case would be:

export TRACE_DATAHUB__EMITTER__REST_EMITTER=true

It would be quite universal piece of code

[hsheth2]

Unfortunately mypy really doesn't like this type of patching

I agree with you that the code duplication isn't ideal, but it's better than having type: ignore everywhere. If there's an alternative that doesn't require that, I'm all ears

[skrydal]

I agree with the spirit of the change with regards to the workunit processor placement. I think we should avoid repeated conditionals when debug logging, proposed a solution in a comment.