uranusjr opened a new pull request, #47659: URL: https://github.com/apache/airflow/pull/47659
The asset_type field in AssetProfile is for distinguishing between different asset-related types (Asset, ref, or alias). However, it used type(obj).__name__, which does not account for subclasses correctly. Since we don't really care about asset subclasses in the scheduler (they are only meaningful to the user, either in UI and at runtime in the task runner), we can simply coerce them into the base class we care about. This means ditching the type() call altogether to just use the base class directly. The field is also renamed to 'type' to avoid confusion since 'asset_type' has another meaning in the Asset class. Two tests on asset ref around this has been marked as xfail since the task runner does not currently handle them correctly. They will be fixed in an upcoming PR. Close #47598. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
