(
joincond: ColumnElement[bool],
collection: _MutableColumnPairs,
)
| 3154 | secondary_sync_pairs: _MutableColumnPairs = [] |
| 3155 | |
| 3156 | def go( |
| 3157 | joincond: ColumnElement[bool], |
| 3158 | collection: _MutableColumnPairs, |
| 3159 | ) -> None: |
| 3160 | def visit_binary( |
| 3161 | binary: BinaryExpression[Any], |
| 3162 | left: ColumnElement[Any], |
| 3163 | right: ColumnElement[Any], |
| 3164 | ) -> None: |
| 3165 | if ( |
| 3166 | "remote" in right._annotations |
| 3167 | and "remote" not in left._annotations |
| 3168 | and self.can_be_synced_fn(left) |
| 3169 | ): |
| 3170 | lrp.add((left, right)) |
| 3171 | elif ( |
| 3172 | "remote" in left._annotations |
| 3173 | and "remote" not in right._annotations |
| 3174 | and self.can_be_synced_fn(right) |
| 3175 | ): |
| 3176 | lrp.add((right, left)) |
| 3177 | if binary.operator is operators.eq and self.can_be_synced_fn( |
| 3178 | left, right |
| 3179 | ): |
| 3180 | if "foreign" in right._annotations: |
| 3181 | collection.append((left, right)) |
| 3182 | elif "foreign" in left._annotations: |
| 3183 | collection.append((right, left)) |
| 3184 | |
| 3185 | visit_binary_product(visit_binary, joincond) |
| 3186 | |
| 3187 | for joincond, collection in [ |
| 3188 | (self.primaryjoin, sync_pairs), |
nothing calls this directly
no test coverage detected