In this PR, we will check if there is a mutation table in the entity source to determine if it is a mutation source. The entity source itself is not enough.
Before this PR:
In the Entity JoinSource case, it will try to generate the mutation data frame. However, there are no mutation related fields like is_before or mutation_time_column. Therefore, the job will exit early with some schema could not resolved error.
Summary
In this PR, we will check if there is a mutation table in the entity source to determine if it is a mutation source. The entity source itself is not enough.
Before this PR: In the Entity JoinSource case, it will try to generate the mutation data frame. However, there are no mutation related fields like
is_beforeormutation_time_column. Therefore, the job will exit early with some schema could not resolved error.Why / Goal
Test Plan
Checklist
Reviewers
@airbnb/zipline-maintainers @nikhilsimha @hanyuli1995 @donghanz @ezvz