S Thelin
07/10/2023, 5:28 AMrtyler
07/10/2023, 2:25 PMS Thelin
07/10/2023, 2:29 PMrtyler
07/10/2023, 3:30 PMObjectStore
trait so that a user can just create the ObjectStore
and let it handle the locking transparently without needing to deal with a bunch of custom code in delta-rsS Thelin
07/10/2023, 4:41 PMJohn Darrington
07/10/2023, 5:06 PMS Thelin
07/11/2023, 7:51 AMfrom redis import StrictRedis, lock
With No Redis Lock
input
df1 = DataFrame({'id': [1]})
df2 = DataFrame({'id': [2]})
df3 = DataFrame({'id': [3]})
df4 = DataFrame({'id': [4]})
Fed via joblib
to ensure to try to mimic a multi process situation.
Here you can see it writes the physical, files, but only 3 commits in the delta log.write_deltalake
so it is not as nice as yours @rtyler but it works from what I can see.
I am tempted to make a quick pypi library where I just expose
write_redis_lock_deltalake
or similar.