pg: address second review of --from-now

Daemon delegation sent --full and --from-now unchanged, so the precedence
resolved on the local path did not apply when the daemon owns the archive:
`pg push --full --from-now` could backfill locally but bound remotely. The
delegated request now carries the resolved value.

Freshness is judged on the state as first read, before the recovery paths can
clear the watermark and boundary state, so a target whose PG marker was lost no
longer looks brand new and cannot be re-bounded.

The incompatible vector configuration is refused before connecting rather than
after, so watch mode does not retry a combination that can never succeed having
already synced locally and opened a stream. The flag help now states the
requirement.

Known limitation, left for maintainer judgement: the boundary is per-push, so
phases that are archive-wide by nature (cursor usage events on later pushes,
project-identity publication) are only skipped on the bounded push itself.
Making that permanent needs the boundary persisted per target, and the right
treatment of identity publication is a product call: skipping it entirely
leaves a bounded target without project identities, while scoping observations
and snapshots to admitted sessions preserves them but is a larger change.

Author: Technophobe01

cmd/agentsview/archive_write_backend.go

@@ -333,7 +333,7 @@ func (b daemonArchiveWriteBackend) PGPush(
 			SyncStateTarget:        target.SyncStateTarget,
 			MigrateLegacySyncState: target.MigrateLegacySyncState,
 			NoVectors:              cfg.NoVectors,
-			FromNow:                cfg.FromNow,
+			FromNow:                cfg.FromNow && !cfg.Full,
 			ScopeVectorsToChangedSessions: cfg.
 				ScopeVectorsToChangedSessions,
 			LastReconciledVectorGeneration: cfg.

cmd/agentsview/cli.go

@@ -652,7 +652,7 @@ func newPGPushCommand() *cobra.Command {
 	cmd.Flags().DurationVar(&cfg.Debounce, "debounce", defaultWatchDebounce, "Coalesce window after a change before pushing (--watch only)")
 	cmd.Flags().DurationVar(&cfg.Interval, "interval", defaultWatchInterval, "Periodic floor push interval (--watch only)")
 	cmd.Flags().BoolVar(&cfg.NoVectors, "no-vectors", false, "Skip pushing semantic-search vectors")
-	cmd.Flags().BoolVar(&cfg.FromNow, "from-now", false, "On a target's FIRST push, start from now instead of backfilling local history (ignored with --full)")
+	cmd.Flags().BoolVar(&cfg.FromNow, "from-now", false, "On a target's FIRST push, start from now instead of backfilling local history (ignored with --full; requires --no-vectors)")
 	return cmd
 }
 

cmd/agentsview/pg.go

@@ -99,6 +99,16 @@ func pgVectorPushSource(
 func runPGPush(
 	cfg PGPushConfig, targetName string,
 ) error {
+	// Refuse up front: the vector phase cannot be bounded, and discovering that
+	// only after connecting leaves watch mode retrying a configuration that can
+	// never succeed, having already synced locally and opened a stream.
+	if cfg.FromNow && !cfg.Full && !cfg.NoVectors {
+		return fmt.Errorf(
+			"--from-now cannot bound the vector phase (it would upload " +
+				"embeddings and raw text for sessions before the boundary); " +
+				"re-run with --no-vectors",
+		)
+	}
 	appCfg, err := config.LoadMinimal()
 	if err != nil {
 		return fmt.Errorf("loading config: %w", err)

internal/postgres/push.go

@@ -178,6 +178,10 @@ func (s *Sync) PushWithOptions(
 			lastPushBoundaryStateKey, err,
 		)
 	}
+	// Freshness must be judged on what was on disk when this push started: the
+	// recovery paths below clear lastPush and boundaryState, which would make an
+	// established target whose marker was lost look brand new.
+	initialLastPush, initialBoundaryState := lastPush, boundaryState
 	pushStateCleared := false
 	if reset, reason := pushTargetState(
 		lastPush,
@@ -301,7 +305,8 @@ func (s *Sync) PushWithOptions(
 	// (watermark, boundary state) and nothing remote (this marker) has ever
 	// recorded a push, and that no reset cleared state on this run.
 	applyFromNow := pushFromNowApplies(
-		s.pushFromNow, lastPush, boundaryState, markerExists, pushStateCleared,
+		s.pushFromNow, initialLastPush, initialBoundaryState,
+		markerExists, pushStateCleared,
 	)
 	// The boundary scopes SESSION selection only. Phases that are archive-wide
 	// would still upload pre-boundary content, defeating the point, so a bounded