/*
/* Copyright 2018-2026 contributors to the OpenLineage project
/* SPDX-License-Identifier: Apache-2.0
*/

package io.openlineage.flink.visitor.lifecycle;

import io.openlineage.flink.client.CheckpointFacet;
import org.apache.flink.api.common.JobExecutionResult;

public interface ExecutionContext {

  void onJobSubmitted();

  void onJobCheckpoint(CheckpointFacet facet);

  void onJobCompleted(JobExecutionResult jobExecutionResult);

  void onJobFailed(Throwable failed);
}
