MCPcopy Index your code
hub / github.com/apache/airflow / _read_result

Method _read_result

airflow/operators/python.py:418–429  ·  view source on GitHub ↗
(self, filename)

Source from the content-addressed store, hash-verified

416 file.write('\n'.join(map(str, self.string_args)))
417
418 def _read_result(self, filename):
419 if os.stat(filename).st_size == 0:
420 return None
421 with open(filename, 'rb') as file:
422 try:
423 return self.pickling_library.load(file)
424 except ValueError:
425 self.log.error(
426 "Error deserializing result. Note that result deserialization "
427 "is not supported across major Python versions."
428 )
429 raise
430
431
432def get_current_context() -> Dict[str, Any]:

Callers 1

execute_callableMethod · 0.95

Calls 1

errorMethod · 0.45

Tested by

no test coverage detected