def get_execution_df()

in tfx_airflow/notebooks/utils.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  def get_execution_df(self, execution_id):
    """Returns a `pd.DataFrame` for an execution with `execution_id`.

    Args:
      execution_id: An `int` indicating the id of an execution in the store.

    Returns:
      A `pd.DataFrame` to display the properties of the execution corresponding
      to `execution_id` or None if no such execution exists in the store.
    """
    executions = self.metadata_store.get_executions_by_id([execution_id])
    return (
        self.get_df_from_single_artifact_or_execution(executions[0])
        if executions else None
    )