Hello maintainers

I recently ran into this nasty error where Airflow's apply_defaults
decorator is reporting (my **kwargs do contain job_flow_id)
airflow.exceptions.AirflowException: Argument ['job_flow_id'] is required

------------

Looking into decorators.py, I felt that sig_cache
<https://github.com/apache/airflow/blob/v1-10-stable/airflow/utils/decorators.py#L53>
might
be messing-up some things. In fact, from the commit that introduced
<https://github.com/apache/airflow/commit/81ec595b6c1ac05bc7f42e2c92c0dd79409953a4>
it,
I cannot figure out how *function-signature caching* is working at all (at
least it isn't working in this way
<https://www.python.org/dev/peps/pep-0362/#no-implicit-caching-of-signature-objects>
)?

------------


   - What could be causing the error?
   - How does sig_cache work and does it need to be cleared forcefully
   under any circumstances? If so, how to clear it?

------------

Please find the complete (elaborated) question on StackOverflow here
<https://stackoverflow.com/q/54529660/3679900>

*Shubham Gupta*
Software Engineer
 zomato

Reply via email to