Airflow Toloka Provider

This library allows you to run crowdsourcing Toloka processes in Apache Airflow - a widely used workflow management system

Here you can find a collection of ready-made Airflow tasks for the most frequently used actions in Toloka-Kit.

Getting started

$ pip install airflow-provider-toloka

A good way to start is to follow the example in this repo.

TolokaHook

TolokaHook is used for getting toloka OAuth token and creating TolokaClient with it. You can get TolokaClient from TolokaHook by calling get_conn() method.

To make an appropriate Airflow Connection you need to create it in the Airflow Connections UI with following parameters:

• Conn ID: toloka_default
• Conn Type: Toloka
• Token: enter your OAuth token for Toloka. You can learn more about how to get it here.
• Environment: enter production or sandbox

Tasks use the toloka_default connection id by default, but if needed, you can create additional Airflow Connections and reference them as the function toloka_conn_id argument.

Tasks and Sensors

There are several tasks and sensors that give you easy way to interact with Toloka from Airflow DAGs. Creating a project and a pool, adding tasks and getting assignments are among them. You can easily create your own task using TolokaHook if it is beyond the scope of implemented ones. And it would be nice to have your pull request with updates.

Check out our example to see tasks and sensors in the battlefield.

Useful Links

• Toloka homepage.
• Apache Airflow homepage.
• Toloka API documentation.
• Toloka-kit usage examples.

Questions and bug reports

• For reporting bugs please use the Toloka/bugreport page.
• Join our English-speaking slack community for both tech and abstract questions.

License

© YANDEX LLC, 2022. Licensed under the Apache License, Version 2.0. See LICENSE file for more details.