View Source Glific.Jobs (Glific v5.1.6)

The Jobs context.

Link to this section Summary

Functions

Gets a single job entry for the organization.

Update a bigquery_job with the message_id and organization_id

Create or update a gcs_job with the message_id and organization_id

Link to this section Functions

Link to this function

get_gcs_job(organization_id)

View Source
@spec get_gcs_job(integer()) :: Glific.GCS.GcsJob.t() | nil

Gets a single job entry for the organization.

Raises Ecto.NoResultsError if the User does not exist.

Link to this function

update_bigquery_job(bigquery_job, attrs)

View Source
@spec update_bigquery_job(Glific.BigQuery.BigQueryJob.t(), map()) ::
  {:ok, Glific.BigQuery.BigQueryJob.t()} | {:error, Ecto.Changeset.t()}

Update a bigquery_job with the message_id and organization_id

Link to this function

update_bigquery_job(organization_id, table, attrs)

View Source
@spec update_bigquery_job(non_neg_integer(), String.t(), map()) ::
  {:ok, Glific.BigQuery.BigQueryJob.t()} | {:error, Ecto.Changeset.t()}

Update a bigquery_job table

@spec update_gcs_job(map()) ::
  {:ok, Glific.GCS.GcsJob.t()} | {:error, Ecto.Changeset.t()}

Create or update a gcs_job with the message_id and organization_id