diff --git a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.import.md b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.import.md
index 1ca6058e7d742d..f30ddeddba92d2 100644
--- a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.import.md
+++ b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.import.md
@@ -9,14 +9,14 @@ Import saved objects from given stream. See the [options](./kibana-plugin-core-s
Signature:
```typescript
-import({ readStream, createNewCopies, namespace, overwrite, }: SavedObjectsImportOptions): Promise;
+import({ readStream, createNewCopies, namespace, overwrite, refresh, }: SavedObjectsImportOptions): Promise;
```
## Parameters
| Parameter | Type | Description |
| --- | --- | --- |
-| { readStream, createNewCopies, namespace, overwrite, } | SavedObjectsImportOptions | |
+| { readStream, createNewCopies, namespace, overwrite, refresh, } | SavedObjectsImportOptions | |
Returns:
diff --git a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.md b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.md
index 18ce27ca2c0dcb..b1035bc247ad16 100644
--- a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.md
+++ b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimporter.md
@@ -21,6 +21,6 @@ export declare class SavedObjectsImporter
| Method | Modifiers | Description |
| --- | --- | --- |
-| [import({ readStream, createNewCopies, namespace, overwrite, })](./kibana-plugin-core-server.savedobjectsimporter.import.md) | | Import saved objects from given stream. See the [options](./kibana-plugin-core-server.savedobjectsimportoptions.md) for more detailed information. |
+| [import({ readStream, createNewCopies, namespace, overwrite, refresh, })](./kibana-plugin-core-server.savedobjectsimporter.import.md) | | Import saved objects from given stream. See the [options](./kibana-plugin-core-server.savedobjectsimportoptions.md) for more detailed information. |
| [resolveImportErrors({ readStream, createNewCopies, namespace, retries, })](./kibana-plugin-core-server.savedobjectsimporter.resolveimporterrors.md) | | Resolve and return saved object import errors. See the [options](./kibana-plugin-core-server.savedobjectsresolveimporterrorsoptions.md) for more detailed information. |
diff --git a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.md b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.md
index 58d0f4bf982c36..775f3a4c9acb3b 100644
--- a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.md
+++ b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.md
@@ -20,4 +20,5 @@ export interface SavedObjectsImportOptions
| [namespace?](./kibana-plugin-core-server.savedobjectsimportoptions.namespace.md) | string | (Optional) if specified, will import in given namespace, else will import as global object |
| [overwrite](./kibana-plugin-core-server.savedobjectsimportoptions.overwrite.md) | boolean | If true, will override existing object if present. Note: this has no effect when used with the createNewCopies
option. |
| [readStream](./kibana-plugin-core-server.savedobjectsimportoptions.readstream.md) | Readable | The stream of [saved objects](./kibana-plugin-core-server.savedobject.md) to import |
+| [refresh?](./kibana-plugin-core-server.savedobjectsimportoptions.refresh.md) | boolean \| 'wait\_for' | (Optional) Refresh setting, defaults to wait_for
|
diff --git a/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.refresh.md b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.refresh.md
new file mode 100644
index 00000000000000..cc7e36354647a5
--- /dev/null
+++ b/docs/development/core/server/kibana-plugin-core-server.savedobjectsimportoptions.refresh.md
@@ -0,0 +1,13 @@
+
+
+[Home](./index.md) > [kibana-plugin-core-server](./kibana-plugin-core-server.md) > [SavedObjectsImportOptions](./kibana-plugin-core-server.savedobjectsimportoptions.md) > [refresh](./kibana-plugin-core-server.savedobjectsimportoptions.refresh.md)
+
+## SavedObjectsImportOptions.refresh property
+
+Refresh setting, defaults to `wait_for`
+
+Signature:
+
+```typescript
+refresh?: boolean | 'wait_for';
+```
diff --git a/src/core/server/saved_objects/import/import_saved_objects.ts b/src/core/server/saved_objects/import/import_saved_objects.ts
index 0631d97b58a72b..9e9f5f8b050dc8 100644
--- a/src/core/server/saved_objects/import/import_saved_objects.ts
+++ b/src/core/server/saved_objects/import/import_saved_objects.ts
@@ -35,6 +35,8 @@ export interface ImportSavedObjectsOptions {
objectLimit: number;
/** If true, will override existing object if present. Note: this has no effect when used with the `createNewCopies` option. */
overwrite: boolean;
+ /** Refresh setting, defaults to `wait_for` */
+ refresh?: boolean | 'wait_for';
/** {@link SavedObjectsClientContract | client} to use to perform the import operation */
savedObjectsClient: SavedObjectsClientContract;
/** The registry of all known saved object types */
@@ -62,6 +64,7 @@ export async function importSavedObjectsFromStream({
typeRegistry,
importHooks,
namespace,
+ refresh,
}: ImportSavedObjectsOptions): Promise {
let errorAccumulator: SavedObjectsImportFailure[] = [];
const supportedTypes = typeRegistry.getImportableAndExportableTypes().map((type) => type.name);
@@ -141,6 +144,7 @@ export async function importSavedObjectsFromStream({
importStateMap,
overwrite,
namespace,
+ refresh,
};
const createSavedObjectsResult = await createSavedObjects(createSavedObjectsParams);
errorAccumulator = [...errorAccumulator, ...createSavedObjectsResult.errors];
diff --git a/src/core/server/saved_objects/import/lib/create_saved_objects.ts b/src/core/server/saved_objects/import/lib/create_saved_objects.ts
index bf58b2bb4b00e0..d6c7cbe934b51b 100644
--- a/src/core/server/saved_objects/import/lib/create_saved_objects.ts
+++ b/src/core/server/saved_objects/import/lib/create_saved_objects.ts
@@ -18,6 +18,7 @@ export interface CreateSavedObjectsParams {
importStateMap: ImportStateMap;
namespace?: string;
overwrite?: boolean;
+ refresh?: boolean | 'wait_for';
}
export interface CreateSavedObjectsResult {
createdObjects: Array>;
@@ -35,6 +36,7 @@ export const createSavedObjects = async ({
importStateMap,
namespace,
overwrite,
+ refresh,
}: CreateSavedObjectsParams): Promise> => {
// filter out any objects that resulted in errors
const errorSet = accumulatedErrors.reduce(
@@ -87,6 +89,7 @@ export const createSavedObjects = async ({
const bulkCreateResponse = await savedObjectsClient.bulkCreate(objectsToCreate, {
namespace,
overwrite,
+ refresh,
});
expectedResults = bulkCreateResponse.saved_objects;
}
diff --git a/src/core/server/saved_objects/import/saved_objects_importer.ts b/src/core/server/saved_objects/import/saved_objects_importer.ts
index f4572e58d6fadf..e9c54f7b44debc 100644
--- a/src/core/server/saved_objects/import/saved_objects_importer.ts
+++ b/src/core/server/saved_objects/import/saved_objects_importer.ts
@@ -66,12 +66,14 @@ export class SavedObjectsImporter {
createNewCopies,
namespace,
overwrite,
+ refresh,
}: SavedObjectsImportOptions): Promise {
return importSavedObjectsFromStream({
readStream,
createNewCopies,
namespace,
overwrite,
+ refresh,
objectLimit: this.#importSizeLimit,
savedObjectsClient: this.#savedObjectsClient,
typeRegistry: this.#typeRegistry,
diff --git a/src/core/server/saved_objects/import/types.ts b/src/core/server/saved_objects/import/types.ts
index ccf58c99f1ad8a..d3a38b48e92cb7 100644
--- a/src/core/server/saved_objects/import/types.ts
+++ b/src/core/server/saved_objects/import/types.ts
@@ -155,6 +155,8 @@ export interface SavedObjectsImportOptions {
namespace?: string;
/** If true, will create new copies of import objects, each with a random `id` and undefined `originId`. */
createNewCopies: boolean;
+ /** Refresh setting, defaults to `wait_for` */
+ refresh?: boolean | 'wait_for';
}
/**
diff --git a/src/core/server/server.api.md b/src/core/server/server.api.md
index 2228c8fee87948..ea83e210cc4e14 100644
--- a/src/core/server/server.api.md
+++ b/src/core/server/server.api.md
@@ -2541,7 +2541,7 @@ export class SavedObjectsImporter {
typeRegistry: ISavedObjectTypeRegistry;
importSizeLimit: number;
});
- import({ readStream, createNewCopies, namespace, overwrite, }: SavedObjectsImportOptions): Promise;
+ import({ readStream, createNewCopies, namespace, overwrite, refresh, }: SavedObjectsImportOptions): Promise;
resolveImportErrors({ readStream, createNewCopies, namespace, retries, }: SavedObjectsResolveImportErrorsOptions): Promise;
}
@@ -2604,6 +2604,7 @@ export interface SavedObjectsImportOptions {
namespace?: string;
overwrite: boolean;
readStream: Readable;
+ refresh?: boolean | 'wait_for';
}
// @public