kliko_play.py

def generate_kliko_task(task, image_name, *args, **kwargs):
    class _task(KlikoTask):
        @classmethod
        def image_name(cls):
            return image_name

        def requires(self):
            return _task(*args, **kwargs)
   
    _task.__name__ = task  
    return _task

h5file = 'blah.h5'
url = 'https://somewhere/' + h5file
output_ms = 'blah.ms'

task_list = [
  generate_kliko_task('DownloadTask', 'vermeerkat/downobs:0.1', url=url),
  generate_kliko_task('h5toms', 'vermeerkat/h5toms:0.1', hdf5_file=h5file, output_ms=output_ms),
]