QuboleFileSensor

Qubole

Wait for a file or folder to be present in cloud storage.

View on GitHub

Last Updated: Oct. 23, 2022

Access Instructions

Install the Qubole provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

qubole_conn_idConnection id which consists of qds auth_token
dataa JSON object containing payload, whose presence needs to be checked Check this example for sample payload structure.

Documentation

Wait for a file or folder to be present in cloud storage.

Check for file or folder presence via QDS APIs.

See also

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

Note

Both data and qubole_conn_id fields support templating. You can also use .txt files for template-driven use cases.

Was this page helpful?