Commit 7fb14dc7 authored by Paul Graydon's avatar Paul Graydon

erp5_wendelin: Improve error handling in ingestion script

See merge request nexedi/wendelin!165
parent eb4706e9
Pipeline #36256 failed with stage
in 0 seconds
from DateTime import DateTime from DateTime import DateTime
from zExceptions import NotFound
now = DateTime() now = DateTime()
today_string = now.strftime('%Y%m%d') today_string = now.strftime('%Y%m%d')
...@@ -116,16 +117,23 @@ if modify and data_ingestion is None: ...@@ -116,16 +117,23 @@ if modify and data_ingestion is None:
# find ingestion line for current resource # find ingestion line for current resource
input_line = None
operation_line = None
for line in data_ingestion.objectValues(portal_type="Data Ingestion Line"): for line in data_ingestion.objectValues(portal_type="Data Ingestion Line"):
if line.getResourceReference() == resource_reference: if line.getResourceReference() == resource_reference:
input_line = line input_line = line
elif line.getResourceValue().getPortalType() == "Data Operation": elif line.getResourceValue().getPortalType() == "Data Operation":
operation_line = line operation_line = line
if input_line is None:
raise NotFound('No relevant data ingestion line found.')
if modify and input_line.getQuantity() == 0: if modify and input_line.getQuantity() == 0:
init_input_line(input_line, operation_line) init_input_line(input_line, operation_line)
if operation_line is None:
raise NotFound('No relevant data operation found.')
data_operation = operation_line.getResourceValue() data_operation = operation_line.getResourceValue()
parameter_dict = { parameter_dict = {
input_line.getReference(): \ input_line.getReference(): \
{v.getPortalType(): v for v in input_line.getAggregateValueList()}} {v.getPortalType(): v for v in input_line.getAggregateValueList()}}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment