@@ -1032,6 +1032,16 @@ def run_req(self, xml_request, task_item):
10321032 def create_extract_req (self , xml_request : ET .Element , extract_item : "TaskItem" ) -> bytes :
10331033 extract_element = ET .SubElement (xml_request , "extractRefresh" )
10341034
1035+ # Main attributes
1036+ extract_element .attrib ["type" ] = extract_item .task_type
1037+
1038+ if extract_item .target is not None :
1039+ target_element = ET .SubElement (extract_element , extract_item .target .type )
1040+ target_element .attrib ["id" ] = extract_item .target .id
1041+
1042+ if extract_item .schedule_item is None :
1043+ return ET .tostring (xml_request )
1044+
10351045 # Schedule attributes
10361046 schedule_element = ET .SubElement (xml_request , "schedule" )
10371047
@@ -1043,17 +1053,11 @@ def create_extract_req(self, xml_request: ET.Element, extract_item: "TaskItem")
10431053 frequency_element .attrib ["end" ] = str (interval_item .end_time )
10441054 if hasattr (interval_item , "interval" ) and interval_item .interval :
10451055 intervals_element = ET .SubElement (frequency_element , "intervals" )
1046- for interval in interval_item ._interval_type_pairs ():
1056+ for interval in interval_item ._interval_type_pairs (): # type: ignore
10471057 expression , value = interval
10481058 single_interval_element = ET .SubElement (intervals_element , "interval" )
10491059 single_interval_element .attrib [expression ] = value
10501060
1051- # Main attributes
1052- extract_element .attrib ["type" ] = extract_item .task_type
1053-
1054- target_element = ET .SubElement (extract_element , extract_item .target .type )
1055- target_element .attrib ["id" ] = extract_item .target .id
1056-
10571061 return ET .tostring (xml_request )
10581062
10591063
0 commit comments