Skip to content

Commit ddd1655

Browse files
committed
rename a few columns and statuses
1 parent 21f84c3 commit ddd1655

4 files changed

Lines changed: 11 additions & 11 deletions

File tree

apps/transport/lib/irve/consolidation.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ defmodule Transport.IRVE.Consolidation do
149149
|> Explorer.DataFrame.select([
150150
"dataset_id",
151151
"resource_id",
152-
"status",
152+
"consolidation_status",
153153
"error_type",
154154
"estimated_pdc_count",
155155
"file_extension",

apps/transport/lib/irve/database_importer.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ defmodule Transport.IRVE.DatabaseImporter do
1717

1818
# return:
1919
# - `:import_successful` if the import went fine
20-
# - `:already_in_db` if the same content (based on file checksum) is in db for
20+
# - `:already_up_to_date` if the same content (based on file checksum) is in db for
2121
# the provided combination of ids
2222
# (else raise an error)
2323
def try_write_to_db(file_path, %{
@@ -40,7 +40,7 @@ defmodule Transport.IRVE.DatabaseImporter do
4040
rescue
4141
e in [Ecto.ConstraintError] ->
4242
if e.type == :unique && e.constraint == "irve_valid_file_datagouv_resource_id_checksum_index" do
43-
:already_in_db
43+
:already_up_to_date
4444
else
4545
reraise(e, __STACKTRACE__)
4646
end

apps/transport/lib/irve/report_item.ex

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@ defmodule Transport.IRVE.ReportItem do
44
IRVE file into a structure with all the same keys.
55
(as expected by the `DataFrame` that we use to create the CSV file).
66
"""
7-
@enforce_keys [:dataset_id, :resource_id, :url, :dataset_title, :status, :estimated_pdc_count]
7+
@enforce_keys [:dataset_id, :resource_id, :url, :dataset_title, :consolidation_status, :estimated_pdc_count]
88
defstruct [
99
:dataset_id,
1010
:resource_id,
1111
:url,
1212
:dataset_title,
1313
:datagouv_organization_or_owner,
1414
:datagouv_last_modified,
15-
:status,
15+
:consolidation_status,
1616
:error_message,
1717
:error_type,
1818
:estimated_pdc_count,
@@ -38,7 +38,7 @@ defmodule Transport.IRVE.ReportItem do
3838
def to_map(%__MODULE__{} = report_row) do
3939
report_row
4040
|> Map.from_struct()
41-
|> Map.update!(:status, &to_string/1)
41+
|> Map.update!(:consolidation_status, &to_string/1)
4242
end
4343

4444
defp new(resource, status, error_message, error_type) do
@@ -49,7 +49,7 @@ defmodule Transport.IRVE.ReportItem do
4949
dataset_title: resource.dataset_title,
5050
datagouv_organization_or_owner: resource.datagouv_organization_or_owner,
5151
datagouv_last_modified: resource.datagouv_last_modified,
52-
status: status,
52+
consolidation_status: status,
5353
estimated_pdc_count: resource[:estimated_pdc_count],
5454
error_message: error_message,
5555
error_type: error_type,

apps/transport/test/transport/irve/consolidation_test.exs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ defmodule Transport.IRVE.ConsolidationTest do
3333
%{
3434
"dataset_id" => "another-dataset-id",
3535
"resource_id" => "another-resource-id",
36-
"status" => "file_level_errors",
36+
"consolidation_status" => "file_level_errors",
3737
"error_type" => nil,
3838
"estimated_pdc_count" => "1",
3939
"file_extension" => ".csv",
@@ -50,7 +50,7 @@ defmodule Transport.IRVE.ConsolidationTest do
5050
%{
5151
"dataset_id" => "individual-published-dataset-id",
5252
"resource_id" => "individual-published-resource-id",
53-
"status" => "producer_not_an_organization",
53+
"consolidation_status" => "producer_not_an_organization",
5454
"error_type" => nil,
5555
"estimated_pdc_count" => "1",
5656
"file_extension" => ".csv",
@@ -63,7 +63,7 @@ defmodule Transport.IRVE.ConsolidationTest do
6363
%{
6464
"dataset_id" => "the-dataset-id",
6565
"resource_id" => "the-resource-id",
66-
"status" => "import_successful",
66+
"consolidation_status" => "import_successful",
6767
"error_type" => nil,
6868
"estimated_pdc_count" => "1",
6969
"file_extension" => ".csv",
@@ -79,7 +79,7 @@ defmodule Transport.IRVE.ConsolidationTest do
7979
|> Explorer.DataFrame.select([
8080
"dataset_id",
8181
"resource_id",
82-
"status",
82+
"consolidation_status",
8383
"error_type",
8484
"estimated_pdc_count",
8585
"file_extension",

0 commit comments

Comments
 (0)