Skip to content

Commit

Permalink
use dockerhub images
Browse files Browse the repository at this point in the history
  • Loading branch information
JanKaul committed Mar 21, 2024
1 parent b0c8b9e commit 05c399a
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 12 deletions.
6 changes: 3 additions & 3 deletions dashtool/src/build/build_dag.rs
Original file line number Diff line number Diff line change
Expand Up @@ -390,7 +390,7 @@ mod tests {
.write_all(
r#"
{
"image": "ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg",
"image": "dashbook/pipelinewise-tap-postgres:iceberg",
"streams": {"inventory-orders": { "identifier": "bronze.inventory.orders" }},
"catalog": "https://api.dashbook.dev/nessie/cat-1w0qookj",
"bucket": "s3://example-postgres/",
Expand Down Expand Up @@ -457,7 +457,7 @@ mod tests {

assert_eq!(
singer.target["image"],
"ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg"
"dashbook/pipelinewise-tap-postgres:iceberg"
);
assert_eq!(singer.target["branch"], "main");
}
Expand Down Expand Up @@ -500,7 +500,7 @@ mod tests {
.write_all(
r#"
{
"image": "ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg",
"image": "dashbook/pipelinewise-tap-postgres:iceberg",
"streams": {"inventory-orders": { "identifier": "bronze.inventory.orders" }},
"catalog": "https://api.dashbook.dev/nessie/cat-1w0qookj",
"bucket": "s3://example-postgres/",
Expand Down
10 changes: 5 additions & 5 deletions dashtool/src/build/update_dag.rs
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,7 @@ mod tests {
.write_all(
r#"
{
"image": "ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg",
"image": "dashbook/pipelinewise-tap-postgres:iceberg",
"streams": {"inventory-orders": { "identifier": "bronze.inventory.orders" }}
}
"#
Expand Down Expand Up @@ -176,7 +176,7 @@ mod tests {

assert_eq!(
singer.target["image"],
"ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg"
"dashbook/pipelinewise-tap-postgres:iceberg"
)
}

Expand Down Expand Up @@ -218,7 +218,7 @@ mod tests {
.write_all(
r#"
{
"image": "ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg",
"image": "dashbook/pipelinewise-tap-postgres:iceberg",
"streams": {"inventory-orders": { "identifier": "bronze.inventory.orders" }},
"catalog": "https://api.dashbook.dev/nessie/cat-1w0qookj",
"bucket": "s3://example-postgres/",
Expand Down Expand Up @@ -325,7 +325,7 @@ mod tests {
.write_all(
r#"
{
"image": "ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg",
"image": "dashbook/pipelinewise-tap-postgres:iceberg",
"streams": {"inventory-orders": { "identifier": "bronze.inventory.orders" }},
"catalog": "https://api.dashbook.dev/nessie/cat-1w0qookj",
"bucket": "s3://example-postgres/",
Expand Down Expand Up @@ -369,7 +369,7 @@ mod tests {

assert_eq!(
singer.target["image"],
"ghcr.io/dashbook/pipelinewise-tap-postgres:iceberg"
"dashbook/pipelinewise-tap-postgres:iceberg"
)
}
}
6 changes: 3 additions & 3 deletions dashtool/src/plugins/dashbook/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -73,11 +73,11 @@ impl Plugin for DashbookPlugin {
}

fn refresh_image(&self) -> &str {
"ghcr.io/dashbook/refresh-iceberg-datafusion:dashbook"
"dashbook/refresh-iceberg-datafusion:dashbook"
}

fn refresh_config(&self, _identifier: &str, _branch: &str) -> Result<String, Error> {
Ok("ghcr.io/dashbook/refresh-iceberg-datafusion:dashbook".to_owned())
Ok("dashbook/refresh-iceberg-datafusion:dashbook".to_owned())
}

fn init_containters(
Expand All @@ -87,7 +87,7 @@ impl Plugin for DashbookPlugin {
UserContainerBuilder::default()
.name("authorization".to_string())
.image(Some(
"ghcr.io/dashbook/dashtool-authorization".to_string(),
"dashbook/dashtool-authorization".to_string(),
))
.volume_mounts(vec![
VolumeMountBuilder::default()
Expand Down
2 changes: 1 addition & 1 deletion dashtool/src/plugins/sql/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ impl Plugin for SqlPlugin {
}

fn refresh_image(&self) -> &str {
"ghcr.io/dashbook/refresh-iceberg-datafusion:sql"
"dashbook/refresh-iceberg-datafusion:sql"
}

fn refresh_config(&self, identifier: &str, branch: &str) -> Result<String, Error> {
Expand Down

0 comments on commit 05c399a

Please sign in to comment.