fixed executeAsync inputs issue

Author: NRHelmi

CHANGELOG.md

@@ -1,4 +1,7 @@
-## main
+## latest
+* Fixed `executeAsync` inputs issue.
+
+## v0.2.0-alpha
 * Added v2 predefined results formats:
 
   - `getTransactions` returns `TransactionsAsyncMultipleResponses`.

README.md

@@ -86,7 +86,7 @@ In order to use the `rai-sdk-java`, you need add this dependency to your project
     <dependency>
         <groupId>com.relationalai</groupId>
         <artifactId>rai-sdk</artifactId>
-        <version>0.2.0-alpha</version>
+        <version>0.2.1-alpha</version>
     </dependency>
 
 You need also to point maven to the SDK GitHub packages repository in the project's POM:

pom.xml

@@ -21,7 +21,7 @@
     <description>The RelationalAI Software Development Kit (SDK) for Java</description>
     <groupId>com.relationalai</groupId>
     <artifactId>rai-sdk-pom</artifactId>
-    <version>0.2.0-alpha</version>
+    <version>0.2.1-alpha</version>
     <packaging>pom</packaging>
     <url></url>
 

rai-sdk-examples/pom.xml

@@ -20,7 +20,7 @@
     <parent>
         <groupId>com.relationalai</groupId>
         <artifactId>rai-sdk-pom</artifactId>
-        <version>0.2.0-alpha</version>
+        <version>0.2.1-alpha</version>
     </parent>
 
     <name>RelationalAI SDK for Java Examples</name>

rai-sdk/pom.xml

@@ -20,7 +20,7 @@
     <parent>
         <groupId>com.relationalai</groupId>
         <artifactId>rai-sdk-pom</artifactId>
-        <version>0.2.0-alpha</version>
+        <version>0.2.1-alpha</version>
     </parent>
 
     <name>RelationalAI SDK for Java Package</name>

rai-sdk/src/main/java/com/relationalai/ArrowRelation.java

@@ -3,8 +3,8 @@
 import java.util.List;
 
 public class ArrowRelation extends Entity {
-    String relationId;
-    List<Object> table;
+    public String relationId;
+    public List<Object> table;
 
     public ArrowRelation(String relationId, List<Object> table) {
         this.relationId = relationId;

rai-sdk/src/main/java/com/relationalai/TransactionAsync.java

@@ -60,6 +60,8 @@ String payload() {
         var inputsList = new ArrayList<>();
         inputs.forEach((k, v) -> inputsList.add(DbAction.makeQueryActionInput(k, v)));
 
+        data.put("v1_inputs", inputsList);
+
         var output = new ByteArrayOutputStream();
         JsonStream.setIndentionStep(0);
         JsonStream.serialize(data, output);

rai-sdk/src/main/java/com/relationalai/TransactionAsyncResponse.java

@@ -10,7 +10,10 @@ public class TransactionAsyncResponse extends TransactionAsyncCompactResponse {
     public String createdBy;
 
     @JsonProperty(value = "created_on", required = true)
-    public String createdOn;
+    public Long createdOn;
+
+    @JsonProperty(value = "finished_at", required = true)
+    public Long finishedAt;
 
     @JsonProperty(value = "database_name", required = true)
     public String databaseName;
@@ -22,19 +25,20 @@ public class TransactionAsyncResponse extends TransactionAsyncCompactResponse {
     public String query;
 
     @JsonProperty(value = "last_requested_interval", required = true)
-    public String lastRequestedInterval;
+    public Long lastRequestedInterval;
 
     public TransactionAsyncResponse() {}
     public TransactionAsyncResponse(
             String id,
             String state,
             String accountName,
             String createdBy,
-            String createdOn,
+            Long createdOn,
+            Long finishedAt,
             String databaseName,
             boolean readOnly,
             String query,
-            String lastRequestedInterval
+            Long lastRequestedInterval
     ) {
         super(id, state);
         this.accountName = accountName;