Calder-Ty opened a new issue, #34563:
URL: https://github.com/apache/airflow/issues/34563

   ## Summary
   
   According to the [REST api 
docs](https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#operation/patch_mapped_task_instance).
   you can patch a task instance state. When you hit the api without sending a
   "dry_run" variable, you get a KeyError (This is from a server running 
version 2.5.3):
   
   ```
   Traceback (most recent call last):
     File "/home/airflow/.local/lib/python3.10/site-packages/flask/app.py", 
line 2528, in wsgi_app
       response = self.full_dispatch_request()
     File "/home/airflow/.local/lib/python3.10/site-packages/flask/app.py", 
line 1825, in full_dispatch_request
       rv = self.handle_user_exception(e)
     File "/home/airflow/.local/lib/python3.10/site-packages/flask/app.py", 
line 1823, in full_dispatch_request
       rv = self.dispatch_request()
     File "/home/airflow/.local/lib/python3.10/site-packages/flask/app.py", 
line 1799, in dispatch_request
       return self.ensure_sync(self.view_functions[rule.endpoint])(**view_args)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/decorator.py",
 line 68, in wrapper
       response = function(request)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/uri_parsing.py",
 line 149, in wrapper
       response = function(request)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/validation.py",
 line 196, in wrapper
       response = function(request)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/validation.py",
 line 399, in wrapper
       return function(request)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/response.py",
 line 112, in wrapper
       response = function(request)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/connexion/decorators/parameter.py",
 line 120, in wrapper
       return function(**kwargs)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/airflow/api_connexion/security.py",
 line 51, in decorated
       return func(*args, **kwargs)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/airflow/utils/session.py", 
line 75, in wrapper
       return func(*args, session=session, **kwargs)
     File 
"/home/airflow/.local/lib/python3.10/site-packages/airflow/api_connexion/endpoints/task_instance_endpoint.py",
 line 594, in patch_task_instance
       if not data["dry_run"]:
   KeyError: 'dry_run'
   ```
   
   The API docs state that dry_run is not required and that it is defaulted to 
false.
   
   This can be reproduced in `main` with the tests by commenting out line 1699 
in
   
[test_task_instance_endpoint.py](https://github.com/apache/airflow/blob/5b0ce3db4d36e2a7f20a78903daf538bbde5e38a/tests/api_connexion/endpoints/test_task_instance_endpoint.py#L1695-L1709)
   
   
   
   


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to