Python consume_loop has grown organically from the POC. This is a single function responsible for the entire SQLFlow processing.
This should be refactored to better separate logic flow from implementation.
This refactor should make it easier for people to learn sqlflow's implementation. It should make it easier to isolate components for unit testing.
Python consume_loop has grown organically from the POC. This is a single function responsible for the entire SQLFlow processing.
This should be refactored to better separate logic flow from implementation.
This refactor should make it easier for people to learn sqlflow's implementation. It should make it easier to isolate components for unit testing.