Leon Kozlowski
MappingLengthMismatch
Parameters for map must all be the same length. Got lengths: {'args': 0, 'kwargs': 2}
load
sync
loads = load.map( sync=[data_usage_per_cycle, sim_status, device_change_history], expected_start_time=unmapped(expected_start_time) )
(Pdb) data_usage_per_cycle ('schema', 'table1', [{'data': 'here'}]) (Pdb) sim_status ('schema', 'table2', [{'data': 'here'}]) (Pdb) device_change_history ('schema', 'table3', [{'data': 'here'}])
Zanie
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.