from disco.job import Job
class FirstJob(Job):
input = ["file://testwords.txt"]
@staticmethod
def map(line, params):
yield int(line) + 1, ""
if __name__ == "__main__":
last = FirstJob().run().wait()
In same folder I created file "testwords.txt" and run mychain.py, I got:
disco.error.JobError: Job FirstJob@529:f4221:5146f failed: Status dead
in disco interface:
AttributeError: 'module' object has no attribute 'FirstJob'
Is it a python path issue?
- Ryan
Trying putting your Job class in a separate Python module. I remember
I was having issues with this a while ago.
Jens
Sent from my iPhone 5
> --
> You received this message because you are subscribed to the Google Groups "Disco-development" group.
> To post to this group, send email to disc...@googlegroups.com.
> To unsubscribe from this group, send email to disco-dev+...@googlegroups.com.
> For more options, visit this group at http://groups.google.com/group/disco-dev?hl=en.
>
To unsubscribe from this group and stop receiving emails from it, send an email to disco-dev+...@googlegroups.com.
To post to this group, send email to disc...@googlegroups.com.
Visit this group at http://groups.google.com/group/disco-dev.
For more options, visit https://groups.google.com/d/optout.