Skip to content
This repository has been archived by the owner on Sep 22, 2021. It is now read-only.

treasure-data/luigi-td

Repository files navigation

Luigi-TD

Build Status Code Health Coverage Status PyPI version Documentation Status

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

License

Apache Software License, Version 2.0