Skip to content

Commit

Permalink
pluralize
Browse files Browse the repository at this point in the history
  • Loading branch information
tdraier committed Dec 23, 2024
1 parent 39a46cb commit f2b3ef7
Show file tree
Hide file tree
Showing 4 changed files with 14 additions and 14 deletions.
10 changes: 5 additions & 5 deletions core/bin/core_api.rs
Original file line number Diff line number Diff line change
Expand Up @@ -102,12 +102,12 @@ impl APIState {
app: app::App,
credentials: run::Credentials,
secrets: run::Secrets,
store_block_result: bool,
store_blocks_results: bool,
) {
let mut run_manager = self.run_manager.lock();
run_manager
.pending_apps
.push((app, credentials, secrets, store_block_result));
.push((app, credentials, secrets, store_blocks_results));
}

async fn stop_loop(&self) {
Expand Down Expand Up @@ -603,7 +603,7 @@ struct RunsCreatePayload {
config: run::RunConfig,
credentials: run::Credentials,
secrets: Vec<Secret>,
store_block_result: Option<bool>,
store_blocks_results: Option<bool>,
}

async fn run_helper(
Expand Down Expand Up @@ -851,7 +851,7 @@ async fn runs_create(
app,
credentials,
secrets,
payload.store_block_result.unwrap_or(true),
payload.store_blocks_results.unwrap_or(true),
);
(
StatusCode::OK,
Expand Down Expand Up @@ -937,7 +937,7 @@ async fn runs_create_stream(
databases_store,
qdrant_clients,
Some(tx.clone()),
payload.store_block_result.unwrap_or(true),
payload.store_blocks_results.unwrap_or(true),
)
.await
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ async function handler(
}

const flags = await getFeatureFlags(owner);
const storeBocksResultst = !flags.includes("disable_run_logs");
const storeBlocksResults = !flags.includes("disable_run_logs");

logger.info(
{
Expand All @@ -302,7 +302,7 @@ async function handler(
credentials,
secrets,
isSystemKey: auth.isSystemKey(),
storeBocksResultst,
storeBlocksResults,
}
);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ async function handler(
const inputDataset = inputConfigEntry ? inputConfigEntry.dataset : null;

const flags = await getFeatureFlags(owner);
const storeBocksResultst = !flags.includes("disable_run_logs");
const storeBlocksResults = !flags.includes("disable_run_logs");

const dustRun = await coreAPI.createRun(owner, auth.groups(), {
projectId: app.dustAPIProjectId,
Expand All @@ -137,7 +137,7 @@ async function handler(
config: { blocks: config },
credentials: credentialsFromProviders(providers),
secrets,
storeBocksResultst,
storeBlocksResults,
});

if (dustRun.isErr()) {
Expand Down
10 changes: 5 additions & 5 deletions types/src/front/lib/core_api.ts
Original file line number Diff line number Diff line change
Expand Up @@ -103,7 +103,7 @@ type CoreAPICreateRunParams = {
credentials: CredentialsType;
secrets: DustAppSecretType[];
isSystemKey?: boolean;
storeBocksResultst?: boolean;
storeBlocksResults?: boolean;
};

type GetDatasetResponse = {
Expand Down Expand Up @@ -307,7 +307,7 @@ export class CoreAPI {
credentials,
secrets,
isSystemKey,
storeBocksResultst = true,
storeBlocksResults = true,
}: CoreAPICreateRunParams
): Promise<CoreAPIResponse<{ run: CoreAPIRun }>> {
const response = await this._fetchWithError(
Expand All @@ -329,7 +329,7 @@ export class CoreAPI {
config: config,
credentials: credentials,
secrets: secrets,
store_blocks_results: storeBocksResultst,
store_blocks_results: storeBlocksResults,
}),
}
);
Expand All @@ -351,7 +351,7 @@ export class CoreAPI {
credentials,
secrets,
isSystemKey,
storeBocksResultst = true,
storeBlocksResults = true,
}: CoreAPICreateRunParams
): Promise<
CoreAPIResponse<{
Expand All @@ -378,7 +378,7 @@ export class CoreAPI {
config: config,
credentials: credentials,
secrets: secrets,
store_blocks_results: storeBocksResultst,
store_blocks_results: storeBlocksResults,
}),
}
);
Expand Down

0 comments on commit f2b3ef7

Please sign in to comment.