connector_utils.py

[astoff]

In _check_df_cols_agree: I'm wondering why the inputs are named df and self_df instead of df1 and df2 or something like that.

Also, you probably want this:

    @@ -130,4 +130,4 @@ def _check_df_cols_agree(
                     df2_cols_not_in_df1,
                 )

    -        log.debug("columns of %s and %s don't agree.", df_name, df_name)
    +        log.debug("columns of %s and %s don't agree.", df_name, self_df_name)