I am trying to learn very simply how luigi works. Just like a newbie, I came up with this code
import luigi class class1(luigi.Task): def requires(self): return class2() def output(self): return luigi.LocalTarget('class1.txt') def run(self): print 'IN class A' class class2(luigi.Task): def requires(self): return [] def output(self): return luigi.LocalTarget('class2.txt') if __name__ == '__main__': luigi.run()
Running this on the command line gives an error saying
raise RuntimeError('Unfulfilled %s at run time: %s' % (deps, ',
source share