Function onError

integrations/linear/src/index.ts:1975–2016

(error: unknown)

}

export function onError(error: unknown): ReturnType<RunTaskErrorCallback> {
  if (error instanceof LinearError) {
    // fail fast on user errors
    if (error.errors?.some((e) => e.userError)) {
      return {
        skipRetrying: true,
      };
    }
  }

  if (!(error instanceof RatelimitedLinearError)) {
    return;
  }

  const rateLimitRemaining = error.raw?.response?.headers?.get("X-RateLimit-Requests-Remaining");
  const rateLimitReset = error.raw?.response?.headers?.get("X-RateLimit-Requests-Reset");

  if (rateLimitRemaining === "0" && rateLimitReset) {
    const resetDate = new Date(Number(rateLimitReset) * 1000);

    return {
      retryAt: resetDate,
      error,
    };
  }

  const queryComplexity = error.raw?.response?.headers?.get("X-Complexity");
  const complexityRemaining = error.raw?.response?.headers?.get("X-RateLimit-Complexity-Remaining");
  const complexityReset = error.raw?.response?.headers?.get("X-RateLimit-Complexity-Reset");

  if (
    (complexityRemaining === "0" || Number(complexityRemaining) < Number(queryComplexity)) &&
    complexityReset
  ) {
    const resetDate = new Date(Number(complexityReset) * 1000);

    return {
      retryAt: resetDate,
      error,
    };
  }
}

export const serializeLinearOutput = <T>(obj: T): Prettify<SerializedLinearOutput<T>> => {
  return JSON.parse(JSON.stringify(obj), (key, value) => {