Luigi-TD

Install

You can install the releases from PyPI.

$ pip install luigi-td

Examples

# tasks.py
import luigi
import luigi_td

class MyQuery(luigi_td.Query):
    type = 'presto'
    database = 'sample_datasets'

    def query(self):
        return "SELECT count(1) FROM www_access"

if __name__ == '__main__':
    luigi.run()

$ export TD_API_KEY="YOUR-API-KEY"
$ python tasks.py MyQuery --local-scheduler

Documentation

• Getting Started

License

Apache Software License, Version 2.0