Skip to content

Commit

Permalink
fixed checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
pavansharma36 committed Sep 5, 2024
1 parent 2c46dde commit 0a78b8a
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 12 deletions.
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
package io.github.pavansharma36.workflow.api.adapter.base;

import io.github.pavansharma36.workflow.api.adapter.Adapter;
import io.github.pavansharma36.workflow.api.serde.Serde;
import io.github.pavansharma36.workflow.api.util.PollDelayGenerator;
import lombok.AccessLevel;
import lombok.RequiredArgsConstructor;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,6 @@
import io.github.pavansharma36.workflow.api.adapter.PersistenceAdapter;
import io.github.pavansharma36.workflow.api.adapter.WorkflowAdapter;
import io.github.pavansharma36.workflow.api.model.ManagerInfo;
import io.github.pavansharma36.workflow.api.serde.Deserializer;
import io.github.pavansharma36.workflow.api.serde.Serde;
import io.github.pavansharma36.workflow.api.serde.Serializer;
import io.github.pavansharma36.workflow.api.util.PollDelayGenerator;
import java.util.Date;
import java.util.List;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package io.github.pavansharma36.workflow.api.adapter.builder;

import io.github.pavansharma36.workflow.api.adapter.Adapter;
import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde;
import io.github.pavansharma36.workflow.api.serde.Serde;
import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde;
import io.github.pavansharma36.workflow.api.util.FixedPollDelayGenerator;
import io.github.pavansharma36.workflow.api.util.PollDelayGenerator;
import io.github.pavansharma36.workflow.api.util.WorkflowException;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

import io.github.pavansharma36.workflow.api.adapter.WorkflowAdapter;
import io.github.pavansharma36.workflow.api.adapter.builder.WorkflowAdapterBuilder;
import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde;
import io.github.pavansharma36.workflow.api.serde.Serde;
import io.github.pavansharma36.workflow.api.serde.jackson.JacksonSerde;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import redis.clients.jedis.JedisPool;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,9 @@
import org.bson.BsonInt32;
import org.bson.Document;

/**
* migration to create indexes in mongo for mongopersistenceadapter.
*/
@RequiredArgsConstructor
public class PersistenceMigration implements Runnable {

Expand Down Expand Up @@ -46,13 +49,11 @@ private void managerInfo() {
private void taskInfo() {
List<IndexModel> indexes = new LinkedList<>();

indexes.add(new IndexModel(new BsonDocument().append(MongoDbQueryHelper.TaskInfo.RUN_ID_KEY,
new BsonInt32(1)),
new IndexOptions().background(true).name("task_info_run_id_idx")));
indexes.add(new IndexModel(new BsonDocument().append(MongoDbQueryHelper.TaskInfo.RUN_ID_KEY,
new BsonInt32(1))
indexes.add(new IndexModel(new BsonDocument().append(
MongoDbQueryHelper.TaskInfo.RUN_ID_KEY, new BsonInt32(1))
.append(MongoDbQueryHelper.TaskInfo.TASK_ID_KEY, new BsonInt32(1)),
new IndexOptions().background(true).name("task_info_run_id_task_id_unique_idx").unique(true)));
new IndexOptions().background(true)
.name("task_info_run_id_task_id_unique_idx").unique(true)));

collection(MongoDbQueryHelper.TaskInfo.collectionName(namespace))
.createIndexes(indexes);
Expand Down

0 comments on commit 0a78b8a

Please sign in to comment.