diff --git a/hrqb/tasks/salary_change_types.py b/hrqb/tasks/salary_change_types.py index 49bae27..11d84d5 100644 --- a/hrqb/tasks/salary_change_types.py +++ b/hrqb/tasks/salary_change_types.py @@ -17,11 +17,12 @@ def requires(self) -> list[luigi.Task]: # pragma: nocover def get_dataframe(self) -> pd.DataFrame: fields = {"hr_personnel_action": "Salary Change Type"} - return ( + salary_types_df = ( self.single_input_dataframe[fields.keys()] .drop_duplicates() .rename(columns=fields) ) + return salary_types_df[~salary_types_df["Salary Change Type"].isna()] class LoadSalaryChangeTypes(QuickbaseUpsertTask):