Jose Ramirez

Hello, here is the task_default_parameters test I am debugging for context. ``` def test_task_default_parameters(tmp_directory, tmp_imports): Path('script.py').write_text(""" # %% tags=["parameters"] upstream = None product = None # %% 1 + 1...

Thanks for pointing me back to the original issue, @edublancas . There was some useful information there that I had forgotten about. I have just pushed some code and have...

I apologize for the delay. I will get back to this later this week.

Hi, I am interested in taking this on if it is available! My proposed change would go in `kafka.py:BaseKafkaQueueConsumerFactory:make_kafka_consumer`. What I'd like to do is iterate through the topics in...