@@ -445,27 +445,31 @@ def replicate(
445445 environment : bool = typer .Option (False , help = "Add environment data to S3" ),
446446):
447447 """Upload data from .duckdb to S3 bucket."""
448+ log .info ("Starting replication process" , bucket = bucket , duckdb_path = duckdb_path )
448449 os .environ ["NINAS3" ] = f"{{type: s3, bucket: { bucket } , use_environment: true }}"
449450 os .environ ["AWS_ACCESS_KEY_ID" ] = access_key
450451 os .environ ["AWS_SECRET_ACCESS_KEY" ] = secret_key
451452 os .environ ["AWS_REGION" ] = region
452453 os .environ ["AWS_ENDPOINT" ] = endpoint_url
453454 os .environ ["DUCKDB" ] = f"{{type: duckdb, instance: { duckdb_path } }}"
454455
456+ log .info ("Hello1" )
455457 if not any ([readers , tags , environment ]):
458+ log .info ("Hello2" )
456459 typer .BadParameter (
457460 "Error: At least one data type must be selected "
458461 "(--readers, --tags, or --environment)"
459462 )
460463 raise typer .Exit (1 )
461464
462465 if not Path (duckdb_path ).exists ():
466+ log .info ("Hello3" )
463467 typer .BadParameter (f"Error: DuckDB file not found at { duckdb_path } " )
464468 raise typer .Exit (1 )
465469
466470 # only include configs for enabled data types that have data
467471 stream_configs = {}
468-
472+ log . info ( "Testing hallo do you come here??" )
469473 if readers and check_table_has_data (duckdb_path , "readers_voltage" , dataset_name ):
470474 stream_configs ["readers" ] = {
471475 "table_name" : f"{ dataset_name } .readers_voltage" ,
0 commit comments