Due to recent updates, all users are required to create an Altair One account to login to the RapidMiner community. Click the Register button to create your account using the same email that you have previously used to login to the RapidMiner community. This will ensure that any previously created content will be synced to your Altair One account. Once you login, you will be asked to provide a username that identifies you to other Community users. Email us at Community with questions.

Why does a process run smoothely on the Studio but on the AI Hub it throws a datatype error?

phauptsphaupts Member Posts: 2 Learner I
My process runs in the AI Studio on my local machine without any error. When running the process on our AI Hub, I get the following error message: 
Ooops. Seems like you have found a bug. Please report it in our community at https://community.rapidminer.com.  Reason: Script terminated abnormally: TypeError: int() argument must be a string, a bytes-like object or a real number, not 'Timestamp'
The data loaded from the database contains columns with datetime values, but no part of the code does anything with those values. The code should be fine as it runs smoothely on my local Studio. What could be the reason for the error message and how could I solve it?


<?xml version="1.0" encoding="UTF-8"?><process version="10.4.001">
<context>
<input/>
<output/>
<macros/>
</context>
<operator activated="true" class="process" compatibility="10.4.001" expanded="true" name="Process">
<parameter key="logverbosity" value="init"/>
<parameter key="random_seed" value="2001"/>
<parameter key="send_mail" value="never"/>
<parameter key="notification_email" value=""/>
<parameter key="process_duration_for_mail" value="30"/>
<parameter key="encoding" value="SYSTEM"/>
<process expanded="true">
<operator activated="true" class="retrieve" compatibility="10.4.001" expanded="true" height="68" name="Retrieve FE_Koelsch" width="90" x="45" y="238">
<parameter key="repository_entry" value="/Connections/SCGSRVSQL16-FE_Ergebnis_Koelsch"/>
</operator>
<operator activated="true" class="jdbc_connectors:read_database" compatibility="10.4.001" expanded="true" height="82" name="Read JsonTable" width="90" x="179" y="136">
<parameter key="define_connection" value="repository"/>
<parameter key="connection_entry" value="//SCG_Test_Rapidminer/Connections/FE_Koelsch"/>
<parameter key="database_system" value="MySQL"/>
<parameter key="define_query" value="query"/>
<parameter key="query" value="SELECT *&#10;FROM &quot;dbo&quot;.&quot;JsonTable&quot;&#10;ORDER BY &quot;jid&quot; ASC&#10;OFFSET (SELECT COUNT(*) FROM &quot;dbo&quot;.&quot;JsonTable&quot;) - 100 ROWS&#10;FETCH NEXT 100 ROWS ONLY;"/>
<parameter key="use_default_schema" value="true"/>
<parameter key="prepare_statement" value="false"/>
<enumeration key="parameters"/>
<parameter key="data_management" value="auto"/>
</operator>
<operator activated="true" class="jdbc_connectors:read_database" compatibility="10.4.001" expanded="true" height="82" name="Read ResultsTable" width="90" x="179" y="238">
<parameter key="define_connection" value="repository"/>
<parameter key="connection_entry" value="//SCG_Test_Rapidminer/Connections/FE_Koelsch"/>
<parameter key="database_system" value="MySQL"/>
<parameter key="define_query" value="query"/>
<parameter key="query" value="SELECT *&#10;FROM &quot;dbo&quot;.&quot;ResultsTable&quot;"/>
<parameter key="use_default_schema" value="true"/>
<parameter key="prepare_statement" value="false"/>
<enumeration key="parameters"/>
<parameter key="data_management" value="auto"/>
</operator>
<operator activated="false" class="filter_example_range" compatibility="10.4.001" expanded="true" height="82" name="Filter Example Range" width="90" x="313" y="136">
<parameter key="first_example" value="20000"/>
<parameter key="last_example" value="20100"/>
<parameter key="invert_filter" value="false"/>
</operator>
<operator activated="true" class="concurrency:join" compatibility="10.4.001" expanded="true" height="82" name="Join" width="90" x="447" y="238">
<parameter key="remove_double_attributes" value="true"/>
<parameter key="join_type" value="inner"/>
<parameter key="use_id_attribute_as_key" value="false"/>
<list key="key_attributes">
<parameter key="rID" value="rid"/>
</list>
<parameter key="keep_both_join_attributes" value="false"/>
</operator>
<operator activated="true" class="python_scripting:execute_python" compatibility="10.1.001" expanded="true" height="103" name="Analyze Features" width="90" x="581" y="238">
<parameter key="script" value="import pandas as pd&#10;import json&#10;&#10;&#10;def json_conv(element):&#10; features_string = element['Features']&#10; tube_length = element['PipeLength']&#10;&#10; # Check if 'Features' is empty, None, or the JSON equivalent of None&#10; if not features_string or features_string == &quot;null&quot;:&#10; return [(0, tube_length)]&#10;&#10; features_json = json.loads(features_string)&#10;&#10; # Check if features_json is None after loading&#10; if features_json is None:&#10; return [(0, tube_length)]&#10;&#10; # Sort features_json by 'Xpos'&#10; features_json.sort(key=lambda x: x['Xpos'])&#10;&#10; # List to store segments without defects&#10; no_defect_segments = []&#10;&#10; # Starting point of the tube&#10; start_point = 0&#10;&#10; for feature in features_json:&#10; defect_start = feature['Xpos'] - feature['Width'] / 2&#10; defect_end = feature['Xpos'] + feature['Width'] / 2&#10;&#10; # Check if segment before this defect is longer than 100mm&#10; if defect_start - start_point &gt;= 100:&#10; no_defect_segments.append((start_point, defect_start))&#10;&#10; # Update the start point for the next segment&#10; start_point = defect_end&#10;&#10; # Check for the last segment of the tube&#10; if tube_length - start_point &gt;= 100:&#10; no_defect_segments.append((start_point, tube_length))&#10;&#10; return no_defect_segments&#10;&#10;&#10;def rm_main(data):&#10; datanew = data&#10; datanew['No_defect_segments'] = datanew.apply(json_conv, axis=1)&#10; return (data, datanew)"/>
<parameter key="notebook_cell_tag_filter" value=""/>
<parameter key="use_default_python" value="true"/>
<parameter key="package_manager" value="conda (anaconda)"/>
<parameter key="conda_environment" value="anaconda3"/>
<parameter key="use_macros" value="false"/>
</operator>
<operator activated="true" class="blending:select_attributes" compatibility="10.4.001" expanded="true" height="82" name="Select Attributes" width="90" x="715" y="238">
<parameter key="type" value="exclude attributes"/>
<parameter key="attribute_filter_type" value="a subset"/>
<parameter key="select_attribute" value=""/>
<parameter key="select_subset" value="Features␞ClassifyData"/>
<parameter key="also_apply_to_special_attributes_(id,_label..)" value="false"/>
</operator>
<operator activated="true" class="store" compatibility="10.4.001" expanded="true" height="68" name="Store" width="90" x="1184" y="238">
<parameter key="repository_entry" value="../Data/DP_Outside_Segments_wo_Defects"/>
</operator>
<connect from_op="Retrieve FE_Koelsch" from_port="output" to_op="Read JsonTable" to_port="connection"/>
<connect from_op="Read JsonTable" from_port="output" to_op="Join" to_port="left"/>
<connect from_op="Read JsonTable" from_port="connection" to_op="Read ResultsTable" to_port="connection"/>
<connect from_op="Read ResultsTable" from_port="output" to_op="Join" to_port="right"/>
<connect from_op="Join" from_port="join" to_op="Analyze Features" to_port="input 1"/>
<connect from_op="Analyze Features" from_port="output 1" to_op="Select Attributes" to_port="example set input"/>
<connect from_op="Select Attributes" from_port="example set output" to_op="Store" to_port="input"/>
<connect from_op="Store" from_port="through" to_port="result 1"/>
<portSpacing port="source_input 1" spacing="0"/>
<portSpacing port="sink_result 1" spacing="0"/>
<portSpacing port="sink_result 2" spacing="0"/>
</process>
</operator>
</process>


Sign In or Register to comment.