PalashPaul-Ingka commented on issue #11377:
URL: https://github.com/apache/airflow/issues/11377#issuecomment-745232500
@djrut please use the below code it working
client_id = os.getenv("CLIENT_ID")
# This should be part of your webserver's URL:
# {tenant-project-id}.appspot.com
webserver_id = os.getenv("TENANT_PROJECT")
# The name of the DAG you wish to trigger
dag_name = os.getenv("DAG_NAME")
webserver_url = (
'https://'
+ webserver_id
+ '.appspot.com/api/experimental/dags/'
+ dag_name
+ '/dag_runs'
)
# Make a POST request to IAP which then Triggers the DAG
run_id = datetime.utcnow().strftime('alpaca_%Y-%m-%dT%H:%M:%S.%f')
conf = {"conf": data}
print(f"JSON body = {conf}")
make_iap_request(
webserver_url, client_id, method='POST', json={"conf": data,
**"run_id": run_id, "replace_microseconds": False**})
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
