from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/PushHttpSource.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettySourceHttpServer.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java"
   contains "import io.mantisrx.runtime.parameter.Parameters;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java"
   contains "import io.mantisrx.runtime.parameter.Parameters;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java"
   contains "import io.mantisrx.runtime.WorkerInfo;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java"
   contains "import io.mantisrx.runtime.parameter.Parameters;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/factory/DefaultIcebergWriterFactory.java"
   contains "import io.mantisrx.runtime.WorkerInfo;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java"
   contains "import io.mantisrx.runtime.source.Source;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java"
   contains "import io.mantisrx.runtime.parameter.SinkParameters;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java"
   contains "import io.mantisrx.runtime.parameter.SinkParameters;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java"
   contains "import io.mantisrx.runtime.Context;"

from: mantis-connectors
to: mantis-runtime
evidence:
 - file: "mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java"
   contains "import io.mantisrx.runtime.Context;"