Description:

airflowprovidertoloka 0.0.8

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.

License

For personal and professional use. You cannot resell or redistribute these repositories in their original state.

Share

• Share on Facebook
• Share on Twitter