Function pollJobStatus

src/job.ts:246–270

()

  pollInterval.unref?.();

  async function pollJobStatus(): Promise<void> {
    if (callbacks.isSettled() || polling) {
      return;
    }

    polling = true;
    try {
      const currentJob = await cloudconvert.jobs.get(jobId);

      if (currentJob.status === 'finished') {
        callbacks.finishJob(currentJob);
        return;
      }

      if (currentJob.status === 'error' || currentJob.status === 'failed') {
        callbacks.failJob(currentJob);
      }
    } catch (error) {
      if (!callbacks.isSettled() && error instanceof Error) {
        logger.error(`Job status polling failed: ${error.message}`);
      }
    } finally {
      polling = false;
    }
  }

  return () => clearInterval(pollInterval);
}