airflow.providers.asana.operators.asana_tasks

Module Contents

class airflow.providers.asana.operators.asana_tasks.AsanaCreateTaskOperator(*, conn_id: str, name: str, task_parameters: Optional[dict] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

This operator can be used to create Asana tasks. For more information on Asana optional task parameters, see https://developers.asana.com/docs/create-a-task

See also

For more information on how to use this operator, take a look at the guide: AsanaCreateTaskOperator

Parameters

  • conn_id (str) -- The Asana connection to use.

  • name (str) -- Name of the Asana task.

  • task_parameters (dict) -- Any of the optional task creation parameters. See https://developers.asana.com/docs/create-a-task for a complete list. You must specify at least one of 'workspace', 'parent', or 'projects' either here or in the connection.

execute(self, context: Dict)[source]
class airflow.providers.asana.operators.asana_tasks.AsanaUpdateTaskOperator(*, conn_id: str, asana_task_gid: str, task_parameters: dict, **kwargs)[source]

Bases: airflow.models.BaseOperator

This operator can be used to update Asana tasks. For more information on Asana optional task parameters, see https://developers.asana.com/docs/update-a-task

See also

For more information on how to use this operator, take a look at the guide: AsanaUpdateTaskOperator

Parameters
execute(self, context: Dict)[source]
class airflow.providers.asana.operators.asana_tasks.AsanaDeleteTaskOperator(*, conn_id: str, asana_task_gid: str, **kwargs)[source]

Bases: airflow.models.BaseOperator

This operator can be used to delete Asana tasks.

See also

For more information on how to use this operator, take a look at the guide: AsanaDeleteTaskOperator

Parameters

  • conn_id (str) -- The Asana connection to use.

  • asana_task_gid (str) -- Asana Task ID to delete.

execute(self, context: Dict)[source]
class airflow.providers.asana.operators.asana_tasks.AsanaFindTaskOperator(*, conn_id: str, search_parameters: Optional[dict] = None, **kwargs)[source]

Bases: airflow.models.BaseOperator

This operator can be used to retrieve Asana tasks that match various filters. See https://developers.asana.com/docs/update-a-task for a list of possible filters.

See also

For more information on how to use this operator, take a look at the guide: AsanaFindTaskOperator

Parameters

  • conn_id (str) -- The Asana connection to use.

  • search_parameters (dict) -- The parameters used to find relevant tasks. You must specify at least one of project, section, tag, user_task_list, or both assignee and workspace either here or in the connection.

execute(self, context: Dict)[source]

Was this entry helpful?