Skip to content

Commit

Permalink
Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
kagkarlsson committed Apr 18, 2024
1 parent 5ab9c07 commit 9c646d4
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,11 +68,13 @@ public class DbSchedulerProperties {
/** What polling-strategy to use. Valid values are: FETCH,LOCK_AND_FETCH */
private PollingStrategyConfig.Type pollingStrategy =
SchedulerBuilder.DEFAULT_POLLING_STRATEGY.type;

/**
* The limit at which more executions are fetched from the database after fetching a full batch.
*/
private double pollingStrategyLowerLimitFractionOfThreads =
SchedulerBuilder.DEFAULT_POLLING_STRATEGY.lowerLimitFractionOfThreads;

/**
* For Type=FETCH, the number of due executions fetched from the database in each batch.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ public class SchedulerTest {

@RegisterExtension
public EmbeddedPostgresqlExtension postgres = new EmbeddedPostgresqlExtension();

// @RegisterExtension
// public ChangeLogLevelsExtension changeLogLevels = new ChangeLogLevelsExtension(
// new ChangeLogLevelsExtension.LogLevelOverride("com.github.kagkarlsson.scheduler",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ public class PostgresqlCompatibilityTest extends CompatibilityTest {

@RegisterExtension
public EmbeddedPostgresqlExtension postgres = new EmbeddedPostgresqlExtension();

// Enable if test gets flaky!
// @RegisterExtension
// public ChangeLogLevelsExtension changeLogLevels = new ChangeLogLevelsExtension(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ public class ExecutorPoolTest {
public EmbeddedPostgresqlExtension postgres = new EmbeddedPostgresqlExtension();

@RegisterExtension public StopSchedulerExtension stopScheduler = new StopSchedulerExtension();

// Enable if test gets flaky!
// @RegisterExtension
// public ChangeLogLevelsExtension changeLogLevels = new ChangeLogLevelsExtension(
Expand Down

0 comments on commit 9c646d4

Please sign in to comment.