(self, filename)
| 393 | return self._read_result(output_filename) |
| 394 | |
| 395 | def _write_args(self, filename): |
| 396 | if self.op_args or self.op_kwargs: |
| 397 | with open(filename, 'wb') as file: |
| 398 | self.pickling_library.dump({'args': self.op_args, 'kwargs': self.op_kwargs}, file) |
| 399 | |
| 400 | def _get_serializable_context_keys(self): |
| 401 | def _is_airflow_env(): |