Skip to content

Instantly share code, notes, and snippets.

@samuell
Created August 5, 2014 12:33
Show Gist options
  • Select an option

  • Save samuell/a26ed88a7b9a932b1736 to your computer and use it in GitHub Desktop.

Select an option

Save samuell/a26ed88a7b9a932b1736 to your computer and use it in GitHub Desktop.
# Note: SomeOtherUpstreamTask - which is a different task than TaskA
class SomeOtherUpstreamTask(luigi.Task):
param1 = luigi.Parameter()
pass # We leave out the details for now
# Here we sub-class the original TaskB and overrides its requires method:
class MyOwnTaskB(TaskB):
param1 = luigi.Parameter()
# Override the requires method:
def requires(self):
return SomeOtherUpstreamTask(param1=self.param1)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment