datayoga
datayoga copied to clipboard
datayoga-io
streaming data pipeline platform
From Oren: ``` I merged it, although the more elegant solution would be to have the schema inherit from some base schema since we just duplicate those query and connect_args...
redis_client.close() just returns the connection back to the pool, see how we can destroy it completely.
if Opcode does not exist, the load strategy should determine the behavior. Currently it is doing APPEND. Should also supposed UPSERT.