Change order right > left

gwaramadze · gwaramadze · commit e68b0c878f3a · 2025-05-09T12:57:53.000+02:00
diff --git a/quixstreams/dataframe/dataframe.py b/quixstreams/dataframe/dataframe.py
@@ -1726,10 +1726,10 @@ def right_func(value, key, timestamp, headers):
                 retention_ms=retention_ms,
             )
 
+        right = right.update(right_func, metadata=True).filter(lambda value: False)
         left = self.apply(left_func, metadata=True).filter(
             lambda value: value is not DISCARDED
         )
-        right = right.update(right_func, metadata=True).filter(lambda value: False)
         return left.concat(right)
 
     def ensure_topics_copartitioned(self, *topics: Topic):

Original file line number	Diff line number	Diff line change
`@@ -1726,10 +1726,10 @@ def right_func(value, key, timestamp, headers):`
`1726`	`1726`	`retention_ms=retention_ms,`
`1727`	`1727`	`)`
`1728`	`1728`
	`1729`	`+ right = right.update(right_func, metadata=True).filter(lambda value: False)`
`1729`	`1730`	`left = self.apply(left_func, metadata=True).filter(`
`1730`	`1731`	`lambda value: value is not DISCARDED`
`1731`	`1732`	`)`
`1732`		`- right = right.update(right_func, metadata=True).filter(lambda value: False)`
`1733`	`1733`	`return left.concat(right)`
`1734`	`1734`
`1735`	`1735`	`def ensure_topics_copartitioned(self, *topics: Topic):`